Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix for: https://issues.apache.org/jira/browse/AMQ-4740

This commit is contained in:
Timothy Bish 2013-10-23 12:23:30 -04:00
parent ae1da749b7
commit 0f09f78f3e
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
activemq-http/src/main/java/org/apache/activemq/transport/ws/StompSocket.java
View File

@ -44,6 +44,7 @@ class StompSocket extends TransportSupport implements WebSocket.OnTextMessage, S
ProtocolConverter protocolConverter = new ProtocolConverter(this, null); ProtocolConverter protocolConverter = new ProtocolConverter(this, null);
StompWireFormat wireFormat = new StompWireFormat(); StompWireFormat wireFormat = new StompWireFormat();
private final CountDownLatch socketTransportStarted = new CountDownLatch(1); private final CountDownLatch socketTransportStarted = new CountDownLatch(1);
private StompInactivityMonitor stompInactivityMonitor = new StompInactivityMonitor(this, wireFormat);
@Override @Override
public void onOpen(Connection connection) { public void onOpen(Connection connection) {
@ -123,7 +124,7 @@ class StompSocket extends TransportSupport implements WebSocket.OnTextMessage, S
@Override @Override
public StompInactivityMonitor getInactivityMonitor() { public StompInactivityMonitor getInactivityMonitor() {
return null; return stompInactivityMonitor;
} }
@Override @Override