java内置activemq无法实现ws
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();
}
}
上面的代码,有哪里不正确的么?为什么ws方式发送消息 连不上broker?
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论