1. 程式人生 > >activeMQ,spring的jmstemplate簡單例子

activeMQ,spring的jmstemplate簡單例子

1.使用的是maven的結構,匯入activeMQ的包

  1. <dependency>
  2.           <groupId>org.apache.activemq</groupId>
  3.           <artifactId>activemq-core</artifactId>
  4.           <version>5.5.0</version>
  5. </dependency>

2.建立“生產者”

①xml配置檔案

  1. <!-- 建立工廠連線 -->
  2.     <beanid="connectionFactory"class
    ="org.apache.activemq.ActiveMQConnectionFactory">
  3.         <propertyname="brokerURL"value="tcp://localhost:61616"/>
  4.     </bean>
  5.     <!-- activeMQ訊息目標 佇列 -->
  6.     <beanid="rantzDestination"class="org.apache.activemq.command.ActiveMQQueue">
  7.         <constructor-argindex="0"value="rantz.marketing.queue"
    ></constructor-arg>
  8.     </bean>
  9.     <!-- activeMQ訊息目標 主題-->
  10.         <!-- <bean id="rantzDestination" class="org.apache.activemq.command.ActiveMQTopic">-->
  11.         <!--     <constructor-arg index="0" value="rantz.marketing.queue"></constructor-arg>-->
  12.         <!-- </bean>-->
  13.     <beanid="jmsTemplate"class="org.springframework.jms.core.JmsTemplate">
  14.         <propertyname="connectionFactory"ref="connectionFactory"/>
  15.     </bean>
  16.     <beanid="marketingGateway"class="com.jms.service.RantzMarketingGatewayImpl">
  17.         <propertyname="jmsTemplate"ref="jmsTemplate"/>
  18.         <propertyname="destination"ref="rantzDestination"/>
  19.     </bean>


java程式碼

主類SpringMain

  1. publicstaticvoid main(String[] args) {  
  2.         /*開始載入spring配置檔案*/
  3.             ApplicationContext context = new ClassPathXmlApplicationContext("classpath:applicationContext.xml");  
  4.             IRantzMarketingGateway rantzMarketingGateway= (RantzMarketingGatewayImpl) context.getBean("marketingGateway");  
  5.             rantzMarketingGateway.sendMotoristInfo();  
  6.             System.out.println("Start ...");  
  7.         }  


訊息傳送類RantzMarketingGatewayImpl

  1. import javax.jms.Destination;  
  2. import javax.jms.JMSException;  
  3. import javax.jms.Message;  
  4. import javax.jms.Session;  
  5. import org.springframework.jms.core.JmsTemplate;  
  6. import org.springframework.jms.core.MessageCreator;  
  7. publicclass RantzMarketingGatewayImpl implements IRantzMarketingGateway {  
  8.     private JmsTemplate jmsTemplate;  
  9.     private Destination destination;  
  10.     public JmsTemplate getJmsTemplate() {  
  11.         return jmsTemplate;  
  12.     }  
  13.     publicvoid setJmsTemplate(JmsTemplate jmsTemplate) {  
  14.         this.jmsTemplate = jmsTemplate;  
  15.     }  
  16.     public Destination getDestination() {  
  17.         return destination;  
  18.     }  
  19.     public

    相關推薦

    springboot整合activemq簡單例子附上原始碼連結

    在springboot的官網拿到工程,並且匯入activeMq的依賴 application.properties檔案  spring.activemq.broker-url=tcp://192.168.66.43:61616  spring.activemq.in-m

    activeMQspring的jmstemplate簡單例子

    1.使用的是maven的結構,匯入activeMQ的包<dependency>          <groupId>org.apache.activemq</groupId>          <artifactId>activemq-core</arti

    Libevent使用例子簡單到復雜

    enable targe 描述 har ron 請求 got memset repl 轉載請註明出處:http://blog.csdn.net/luotuo44/article/details/39670221 本文從簡單到復雜,展示如何使用l

    Javaweb專案簡單應用Apache POI匯出Excel的簡單例子

    直接上程式碼: jsp: 說明:這裡使用ajax請求是會有問題的,會導致瀏覽器視窗不會彈出下載提示和選擇位址列的彈窗 //匯出 $('#btn-export').click(function () { location.href = "${pageContext.r

    numpy轉置及軸對換transpose函式簡單例子理解 axis 01 交換圖視覺化 numpy轉置及軸對換transpose函式簡單例子理解

    原 numpy轉置及軸對換transpose函式簡單例子理解 2018年02月01日 22:03:20 末流大學倒三爛 閱讀數:162

    python3傳送郵件02(簡單例子帶附件)

    #!/usr/bin/env python# -*- coding:UTF-8 -*- import osimport smtplibfrom email.header import Headerfrom email.mime.text import MIMETextfrom email.mime.mult

    理解HashMap底層原理一個簡單的HashMap例子

    amp builder out print node get bject sta value package com.jl.testmap; /** * 自定義一個HashMap * @author JiangLai * */ public c

    Eureka伺服器簡單例子

    伺服器概念: Eureka支援叢集部署,實現高可用。 Eureka沒有提供後臺的儲存,所有註冊的服務都被儲存在記憶體中的註冊中心。他們通過心跳儲存著最新的狀態。 客戶端存在相同的機制,同樣在記憶體中儲存了登錄檔資訊,這樣的機制提升了 eureka的效能。使得每次請求不必

    020自定義BaseAdapter然後繫結ListView的最簡單例子

    1 首先在drawable/中匯入7張圖片 2寫一個名為activity_item.xml 檔案 <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" android:

    Spring學習筆記(一):眼見為實先上一個簡單例子

    概述 所謂眼見為實,Spring雖然是一個輕量級的框架,但涉及眾多的概念,理解起來並不容易,因此,先參考資料寫一個簡單的Demo,從中洞見Spring的大體工作流程,為後面深入學習做鋪墊。 本文的Demo很簡單:模擬圖書資料訪問服務,即向資料庫中新增圖書資訊,涉及IBoo

    使用兩個棧實現佇列簡單例子

    棧, 取值是先進後出 ,後進先出。 那麼怎麼能按照佇列方式(先進先出)存值後取值呢? 看以下程式碼: import java.util.Stack; /** * @Author : JCccc * @Description : * @Point: Keep a good mood

    ActiveMQ的傳送與接收 簡單例子和監聽配置

    簡單傳送例項: package com.xuwei.activemq; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.DeliveryMode; impor

    openssl rsa 加密解密簽名驗籤簡單例子

    #include<openssl/pem.h> #include<openssl/ssl.h> #include<openssl/rsa.h> #include<openssl/evp.h> #include<opens

    javaweb之Session簡單例子(兩個頁面一個存資料一個取資料)和session的一些基本內容

    package test.session; import java.io.IOException; import javax.servlet.ServletException; import javax.servlet.http.Cookie; import javax

    npm install —— 從一個簡單例子看本地安裝與全域性安裝的區別

    npm的包安裝分為本地安裝(local)、全域性安裝(global)兩種,從敲的命令列來看,差別只是有沒有-g而已,比如 npm install grunt # 本地安裝 npm install -g grunt-cli # 全域性安裝 這兩種安裝方式有什麼區別呢?從

    今天有群友不是很清楚htm直接存資料庫的危害簡單舉個例子

     通過這個案例就知道為什麼不要把原生的html放資料庫了  常見的幾種轉碼  常用的幾種顯示方法 只有原生html和最下面一種彈框了,變成了持久xss 如果是Ajax的方式,請用@Ajax.JavaScriptStringEncode(xxx) 這個是舉的簡單例子,其實還有更多方

    主裝置號和file_operations結構關係; ioctl和unlocked_ioctl ioctl簡單測試例子

    open一個字元裝置的過程是從 VFS層open系統呼叫 ===> def_chr_fops-->open ===> cdev->fops->open ===> device specific operation 如果是同一類裝置,比

    QThread一個最簡單的掛起恢復的例子

    class MyWorker: public QThread { private: QMutex sync; QWaitCondition pauseCond; bool is

    Libevent使用例子簡單到複雜

            本文從簡單到複雜,展示如何使用libevent。網上的許多例子都是隻有伺服器端的,本文裡面客戶端和伺服器端都有,以饗讀者。         關於libevent程式設計時的一些疑問可以閱讀《libevent程式設計疑難解答》。假如讀者還想了解libe

    JFreeChart簡單例子_建立柱狀圖(當遇到中文亂碼時將各個部分的字型分別設定一下就行了)

          public static JFreeChart getChart(CategoryDataset dataset)     {         //此標題  ‘某社團各部門 ’將被後面的chart.setTitle的標題  ‘某社團各部門柱狀圖’ 覆蓋         JFreeChart ch