增加mq消费者
This commit is contained in:
parent
e437392ff9
commit
33578337e8
|
@ -0,0 +1,38 @@
|
|||
package com.zheng.cms.jms;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
||||
|
||||
import javax.jms.JMSException;
|
||||
import javax.jms.Message;
|
||||
import javax.jms.MessageListener;
|
||||
import javax.jms.TextMessage;
|
||||
|
||||
/**
|
||||
* MQ消费者
|
||||
* Created by ZhangShuzheng on 2016/11/24.
|
||||
*/
|
||||
public class defaultQueueMessageListener implements MessageListener {
|
||||
|
||||
private static Logger _log = LoggerFactory.getLogger(defaultQueueMessageListener.class);
|
||||
|
||||
@Autowired
|
||||
ThreadPoolTaskExecutor threadPoolTaskExecutor;
|
||||
|
||||
public void onMessage(final Message message) {
|
||||
// 使用线程池多线程处理
|
||||
threadPoolTaskExecutor.execute(new Runnable() {
|
||||
public void run() {
|
||||
TextMessage textMessage = (TextMessage) message;
|
||||
try {
|
||||
_log.info("defaultQueueMessageListener接收到:{}", textMessage.getText());
|
||||
} catch (JMSException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
}
|
Loading…
Reference in New Issue