u010956619
小小鱼来喽
采纳率55.6%
2017-11-21 10:50

activemq与websocket结合无法向前台推送

10

activemq接收到消息后,调用websocket的convertAndSend接口向前台发送消息,前台接收不到。但是通过在controller里面编写测试代码,调用convertAndSend进行发送,前台是可以接收到信息的。请问是怎么回事呢。
activemq的接收端代码:
@Service
public class CalculateQueueReceiver implements MessageListener {
@Autowired
private MessageSendMaster messageSendMaster;

@Override
public void onMessage(Message message) {
    ActiveMQBytesMessage bytesMessage = (ActiveMQBytesMessage) message;
    String s = new String(bytesMessage.getContent().getData());
    System.out.println(new Date() + s);
    messageSendMaster.sendMessage(s);
}

}
@Component
public class MessageSendMaster {
private static Logger logger = Logger.getLogger(MessageSendMaster.class);
@Autowired
private SimpMessagingTemplate template;

public void sendMessage(String  message){
    try {
        template.convertAndSend("/topic/calculate", message);
    } catch (Exception e) {
        logger.error(e.getMessage(), e);
        e.printStackTrace();
    }
}

}

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享
  • 邀请回答

1条回答

  • wc936248 wc936248 3年前

    断点看一下 有没有报错 或者堵塞

    点赞 评论 复制链接分享

相关推荐