From c29ec46c7feb7bd8af451a5e6a28411b021b1321 Mon Sep 17 00:00:00 2001 From: skynetcapital <67430414+skynetcapital@users.noreply.github.com> Date: Sun, 27 Jun 2021 22:39:09 -0700 Subject: [PATCH] Add processed commitment to accountSubscribe. Bump version to 1.6-SNAPSHOT --- pom.xml | 2 +- .../java/org/p2p/solanaj/ws/SubscriptionWebSocketClient.java | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/pom.xml b/pom.xml index ca0d6432..ba79d810 100644 --- a/pom.xml +++ b/pom.xml @@ -4,7 +4,7 @@ org.p2p solanaj jar - 1.5 + 1.6-SNAPSHOT solanaj https://github.com/skynetcapital/solanaj diff --git a/src/main/java/org/p2p/solanaj/ws/SubscriptionWebSocketClient.java b/src/main/java/org/p2p/solanaj/ws/SubscriptionWebSocketClient.java index 57fb4d88..521d19a7 100644 --- a/src/main/java/org/p2p/solanaj/ws/SubscriptionWebSocketClient.java +++ b/src/main/java/org/p2p/solanaj/ws/SubscriptionWebSocketClient.java @@ -17,6 +17,7 @@ import org.p2p.solanaj.rpc.types.RpcNotificationResult; import org.p2p.solanaj.rpc.types.RpcRequest; import org.p2p.solanaj.rpc.types.RpcResponse; +import org.p2p.solanaj.rpc.types.config.Commitment; import org.p2p.solanaj.ws.listeners.NotificationEventListener; public class SubscriptionWebSocketClient extends WebSocketClient { @@ -69,7 +70,7 @@ public SubscriptionWebSocketClient(URI serverURI) { public void accountSubscribe(String key, NotificationEventListener listener) { List params = new ArrayList<>(); params.add(key); - params.add(Map.of("encoding", "jsonParsed")); + params.add(Map.of("encoding", "jsonParsed", "commitment", Commitment.PROCESSED.getValue())); RpcRequest rpcRequest = new RpcRequest("accountSubscribe", params);