activeMQ,spring的jmstemplate簡單例子
1.使用的是maven的結構,匯入activeMQ的包
- <dependency>
- <groupId>org.apache.activemq</groupId>
- <artifactId>activemq-core</artifactId>
- <version>5.5.0</version>
- </dependency>
2.建立“生產者”
①xml配置檔案
- <!-- 建立工廠連線 -->
- <beanid="connectionFactory"class
- <propertyname="brokerURL"value="tcp://localhost:61616"/>
- </bean>
- <!-- activeMQ訊息目標 佇列 -->
- <beanid="rantzDestination"class="org.apache.activemq.command.ActiveMQQueue">
- <constructor-argindex="0"value="rantz.marketing.queue"
- </bean>
- <!-- activeMQ訊息目標 主題-->
- <!-- <bean id="rantzDestination" class="org.apache.activemq.command.ActiveMQTopic">-->
- <!-- <constructor-arg index="0" value="rantz.marketing.queue"></constructor-arg>-->
- <!-- </bean>-->
- <beanid="jmsTemplate"class="org.springframework.jms.core.JmsTemplate">
- <propertyname="connectionFactory"ref="connectionFactory"/>
- </bean>
- <beanid="marketingGateway"class="com.jms.service.RantzMarketingGatewayImpl">
- <propertyname="jmsTemplate"ref="jmsTemplate"/>
- <propertyname="destination"ref="rantzDestination"/>
- </bean>
②java程式碼
主類SpringMain
- publicstaticvoid main(String[] args) {
- /*開始載入spring配置檔案*/
- ApplicationContext context = new ClassPathXmlApplicationContext("classpath:applicationContext.xml");
- IRantzMarketingGateway rantzMarketingGateway= (RantzMarketingGatewayImpl) context.getBean("marketingGateway");
- rantzMarketingGateway.sendMotoristInfo();
- System.out.println("Start ...");
- }
訊息傳送類RantzMarketingGatewayImpl
- import javax.jms.Destination;
- import javax.jms.JMSException;
- import javax.jms.Message;
- import javax.jms.Session;
- import org.springframework.jms.core.JmsTemplate;
- import org.springframework.jms.core.MessageCreator;
- publicclass RantzMarketingGatewayImpl implements IRantzMarketingGateway {
- private JmsTemplate jmsTemplate;
- private Destination destination;
- public JmsTemplate getJmsTemplate() {
- return jmsTemplate;
- }
- publicvoid setJmsTemplate(JmsTemplate jmsTemplate) {
- this.jmsTemplate = jmsTemplate;
- }
- public Destination getDestination() {
- return destination;
- }
- public
相關推薦
springboot整合activemq簡單例子,附上原始碼連結
在springboot的官網拿到工程,並且匯入activeMq的依賴 application.properties檔案 spring.activemq.broker-url=tcp://192.168.66.43:61616 spring.activemq.in-m
activeMQ,spring的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