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

NO-JIRA Allow for the disconnect call in the test to fail as the short 

keepAlive interval can trigger a shutdown of the socket before we have a
chance to write the disconnect depending on the timing.
This commit is contained in:
Timothy Bish 2016-03-17 14:08:09 -04:00
parent 2788bd5584
commit 30d6ad72fa
3 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty9/MQTTSocket.java
View File

@ -80,7 +80,7 @@ public class MQTTSocket extends AbstractMQTTSocket implements WebSocketListener
try {
getProtocolConverter().onMQTTCommand(new DISCONNECT().encode());
} catch (Exception e) {
LOG.warn("Failed to close WebSocket", e);
LOG.debug("Failed to close MQTT WebSocket cleanly", e);
}
}

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

@ -64,11 +64,11 @@ public class StompSocket extends AbstractStompSocket implements WebSocketListene
public void onWebSocketClose(int arg0, String arg1) {
try {
if (protocolLock.tryLock() || protocolLock.tryLock(ORDERLY_CLOSE_TIMEOUT, TimeUnit.SECONDS)) {
LOG.info("Stomp WebSocket closed: code[{}] message[{}]", arg0, arg1);
LOG.debug("Stomp WebSocket closed: code[{}] message[{}]", arg0, arg1);
protocolConverter.onStompCommand(new StompFrame(Stomp.Commands.DISCONNECT));
}
} catch (Exception e) {
LOG.warn("Failed to close WebSocket", e);
LOG.debug("Failed to close STOMP WebSocket cleanly", e);
} finally {
if (protocolLock.isHeldByCurrentThread()) {
protocolLock.unlock();

4
activemq-http/src/test/java/org/apache/activemq/transport/ws/StompWSTransportTest.java
View File

@ -283,6 +283,10 @@ public class StompWSTransportTest extends WSTransportTestSupport {
service.shutdownNow();
service.awaitTermination(5, TimeUnit.SECONDS);
try {
wsStompConnection.sendFrame(new StompFrame(Stomp.Commands.DISCONNECT));
} catch (Exception ex) {
LOG.info("Caught exception on write of disconnect", ex);
}
}
}