Destination

配置信息

<!-- 配置消息的Destination對(duì)象 --> <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>

添加監(jiān)聽(tīng)器

ItemAddMessageListener
監(jiān)聽(tīng)添加商品事件

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);// 根據(jù)商品id查詢數(shù)據(jù)，取商品信息// 等待事務(wù)提交Thread.sleep(1000);SearchItem searchItem = searchItemMapper.getItemById(itemId);// 創(chuàng)建文檔對(duì)象SolrInputDocument document = new SolrInputDocument();// 向文檔對(duì)象中添加域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());// 把文檔對(duì)象寫入索引庫(kù)solrServer.add(document);// 提交solrServer.commit();} catch (Exception e) {e.printStackTrace();}}}

配置監(jiān)聽(tīng)器

ItemAddMessageListener

<!-- 配置消息的接收者 --> <!-- 配置監(jiān)聽(tīng)器 --> <bean id="myMessageListener" class="com.taotao.search.listener.MyMessageListener"/> <!-- 消息監(jiān)聽(tīng)容器 --> <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>

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。