美文网首页
Springboot ActiveMQ Consumer

Springboot ActiveMQ Consumer

作者: 曹振华 | 来源:发表于2017-04-25 21:00 被阅读69次
@Component
public class ActiveMQConsumer {

private static final Logger logger = LoggerFactory.getLogger(UserEventService.class);


@JmsListener(destination = "fht.postmessage.queue", containerFactory = "jmsListenerContainerFactory4Queue",subscription = "sub_01" )
public void receiveQueue(Message message) {
    try {
        if (message instanceof TextMessage) {
            String textMessage = ((TextMessage) message).getText();
            sendMessage(textMessage);
            message.acknowledge();
        }
    } catch (JMSException e) {
        e.printStackTrace();
    }
}
}

相关文章

网友评论

      本文标题:Springboot ActiveMQ Consumer

      本文链接:https://www.haomeiwen.com/subject/ielbzttx.html