ActiveMQ使用spring JmsTemplate生成和订阅消息(二)

发布于:2021-10-22 17:28:24

生成类:



@Component("topicProvider")
public class TopicProvider {
@Resource
private JmsTemplate topicJmsTemplate;

/**
* 向指定的topic发布消息
*
* @param topic
* @param msg
*/
public void publish(final Destination topic, final String msg) {

topicJmsTemplate.send(topic, new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
System.out.println("topic name 是" + topic.toString()
+ ",发布消息内容为: " + msg);
return session.createTextMessage(msg);
}
});
}
} 监听器:



public class TopicMessageListener implements MessageListener{
public void onMessage(Message message) {
TextMessage tm = (TextMessage) message;
try {
System.out.println("订阅者1 " + tm.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
} spirng配置:




xmlns:context="http://www.springframework.org/schema/context"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.1.xsd">









guo_topic














class="org.springframework.jms.listener.DefaultMessageListenerContainer">








相关推荐

最新更新

猜你喜欢