public class MQServer {
public static void main(String[] args) throws Exception {
BrokerService broker = new BrokerService();
broker.setBrokerName("MQServerDemo");
broker.setPersistent(false);
// broker.setUseJmx(true);
broker.addConnector("tcp://0.0.0.0:61626");
broker.addConnector(new URI("ws://0.0.0.0:61614"));
broker.addConnector("stomp://0.0.0.0:61613");
broker.addConnector("mqtt://0.0.0.0:1883");
broker.addConnector("ssl://localhost:61627");
broker.start();
}
}
is there anything wrong with the above code? Why can"t ws send messages connect to broker?