Fix ConsumerHandler in WebSocket Proxy (apache#875)

willome · Nov 1, 2017 · 9f63fa7 · 9f63fa7
1 parent 5a4dd11
commit 9f63fa7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ConsumerHandler.java b/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ConsumerHandler.java
@@ -112,7 +112,7 @@ public ConsumerHandler(WebSocketService service, HttpServletRequest request, Ser
 
     private void receiveMessage() {
         if (log.isDebugEnabled()) {
-            log.debug("[{}] [{}] [{}] Receive next message", getSession().getRemoteAddress(), topic, subscription);
+            log.debug("[{}:{}] [{}] [{}] Receive next message", request.getRemoteAddr(), request.getRemotePort(), topic, subscription);
         }
 
         consumer.receiveAsync().thenAccept(msg -> {