Springboot ActiveMQ Consumer

2017-04-25  本文已影响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();
    }
}
}
上一篇 下一篇

猜你喜欢

热点阅读