diff --git a/src/main/java/com/corundumstudio/socketio/transport/XHRPollingClient.java b/src/main/java/com/corundumstudio/socketio/transport/XHRPollingClient.java index 108e43d..cec771e 100644 --- a/src/main/java/com/corundumstudio/socketio/transport/XHRPollingClient.java +++ b/src/main/java/com/corundumstudio/socketio/transport/XHRPollingClient.java @@ -50,7 +50,8 @@ public class XHRPollingClient extends MainBaseClient { } public ChannelFuture send(final Packet packet) { - ChannelPromise promise = getChannel().newPromise(); + Channel currChannel = getChannel(); + ChannelPromise promise = currChannel.newPromise(); promise.addListener(new GenericFutureListener>() { @Override public void operationComplete(Future future) throws Exception { @@ -62,7 +63,7 @@ public class XHRPollingClient extends MainBaseClient { } }); - return getChannel().write(new XHRPacketMessage(getSessionId(), origin, packet), promise); + return currChannel.write(new XHRPacketMessage(getSessionId(), origin, packet), promise); } }