no call session.close() in onWebSocketError() (apache#378)

ldlzp · Apr 24, 2017 · 2f1c5fa · 2f1c5fa
1 parent f13606e
commit 2f1c5fa
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/pulsar-websocket/src/main/java/com/yahoo/pulsar/websocket/AbstractWebSocketHandler.java b/pulsar-websocket/src/main/java/com/yahoo/pulsar/websocket/AbstractWebSocketHandler.java
@@ -92,7 +92,6 @@ public void onWebSocketError(Throwable cause) {
         super.onWebSocketError(cause);
         log.info("[{}] WebSocket error on topic {} : {}", getSession().getRemoteAddress(), topic, cause.getMessage());
         try {
-            getSession().close();
             close();
         } catch (IOException e) {
             log.error("Failed in closing producer for topic[{}] with error: [{}]: ", topic, e.getMessage());