Destination

配置信息

<!-- 配置消息的Destination對象 --> <bean id="test-queue" class="org.apache.activemq.command.ActiveMQQueue"><constructor-arg name="name" value="test-queue"></constructor-arg> </bean> <bean id="itemAddTopic" class="org.apache.activemq.command.ActiveMQTopic"><constructor-arg name="name" value="item-add-topic"></constructor-arg> </bean>

添加監聽器

ItemAddMessageListener
監聽添加商品事件

public class ItemAddMessageListener implements MessageListener {@Autowiredprivate SearchItemMapper searchItemMapper;@Autowiredprivate SolrServer solrServer;@Overridepublic void onMessage(Message message) {try {// 從消息中取商品idTextMessage textMessage = (TextMessage) message;String text = textMessage.getText();long itemId = Long.parseLong(text);// 根據商品id查詢數據，取商品信息// 等待事務提交Thread.sleep(1000);SearchItem searchItem = searchItemMapper.getItemById(itemId);// 創建文檔對象SolrInputDocument document = new SolrInputDocument();// 向文檔對象中添加域document.addField("id", searchItem.getId());document.addField("item_title", searchItem.getTitle());document.addField("item_sell_point", searchItem.getSell_point());document.addField("item_price", searchItem.getPrice());document.addField("item_image", searchItem.getImage());document.addField("item_category_name", searchItem.getCategory_name());document.addField("item_desc", searchItem.getItem_desc());// 把文檔對象寫入索引庫solrServer.add(document);// 提交solrServer.commit();} catch (Exception e) {e.printStackTrace();}}}

配置監聽器

ItemAddMessageListener

<!-- 配置消息的接收者 --> <!-- 配置監聽器 --> <bean id="myMessageListener" class="com.taotao.search.listener.MyMessageListener"/> <!-- 消息監聽容器 --> <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer"><property name="connectionFactory" ref="connectionFactory" /><property name="destination" ref="test-queue" /><property name="messageListener" ref="myMessageListener" /> </bean> <bean id="itemAddMessageListener" class="com.taotao.search.listener.ItemAddMessageListener"/> <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer"><property name="connectionFactory" ref="connectionFactory" /><property name="destination" ref="itemAddTopic" /><property name="messageListener" ref="itemAddMessageListener" /> </bean>

總結

以上是生活随笔為你收集整理的ActiveMQ添加商品接收消息的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。