Fix close race

thegridman · Feb 3, 2025 · 24a6015 · 24a6015
1 parent e32ccfb
commit 24a6015
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/...src/main/java/com/oracle/coherence/grpc/client/common/topics/GrpcSubscriberConnector.java b/...src/main/java/com/oracle/coherence/grpc/client/common/topics/GrpcSubscriberConnector.java
@@ -506,8 +506,11 @@ protected Map<Integer, SeekResult> handleSeekResponse(SeekResponse response)
     @Override
     public void closeSubscription(ConnectedSubscriber<V> subscriber, boolean fDestroyed)
         {
-        f_connection.send(0, TopicServiceRequestType.DestroySubscriber, Int32Value.of(f_nProxyId));
-        f_connection.close();
+        if (f_connection.isConnected())
+            {
+            f_connection.send(0, TopicServiceRequestType.DestroySubscriber, Int32Value.of(f_nProxyId));
+            f_connection.close();
+            }
         }
 
     @Override