<property name="destination" ref="QueueDestination" />
<!--<property name="destination" ref="topicDestination" />-->
<property name="messageListener" ref="queueMessageListener" />
</bean>
可以看到,当使用消息监听器之后,每发送一条消息立马就会被监听到:
第二种方式————发布/订阅(Topic)
同步的方式
类似点对点中同步的方式,只是每个消费者都能收到生产者发出的全部消息,不再赘述。
异步监听的方式
启动两个监听器(两个消费者),对消息进行异步监听。看是否各自能收到生产者发送的消息。
<!-- 配置两个监听器 -->
<bean id="messageListener" class="com.service.TopicMessageListener" />
<bean id="messageListener2" class="com.service.TopicMessageListener2" />
可以看到,每个监听器各自都收到了生产者发送的10条消息。