Fix failing tests and upgrade websocket to Jetty 9.0.5
This commit is contained in:
@@ -59,6 +59,8 @@ public class SimpleBrokerMessageHandlerTests {
|
||||
@Test
|
||||
public void subcribePublish() {
|
||||
|
||||
this.messageHandler.start();
|
||||
|
||||
this.messageHandler.handleMessage(createSubscriptionMessage("sess1", "sub1", "/foo"));
|
||||
this.messageHandler.handleMessage(createSubscriptionMessage("sess1", "sub2", "/foo"));
|
||||
this.messageHandler.handleMessage(createSubscriptionMessage("sess1", "sub3", "/bar"));
|
||||
@@ -85,6 +87,8 @@ public class SimpleBrokerMessageHandlerTests {
|
||||
String sess1 = "sess1";
|
||||
String sess2 = "sess2";
|
||||
|
||||
this.messageHandler.start();
|
||||
|
||||
this.messageHandler.handleMessage(createSubscriptionMessage(sess1, "sub1", "/foo"));
|
||||
this.messageHandler.handleMessage(createSubscriptionMessage(sess1, "sub2", "/foo"));
|
||||
this.messageHandler.handleMessage(createSubscriptionMessage(sess1, "sub3", "/bar"));
|
||||
|
||||
Reference in New Issue
Block a user