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();
}
}
}