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
网友评论