2. 程式人生 > >spring的jms:用spring的JmsTemplate傳送和接收訊息

spring的jms:用spring的JmsTemplate傳送和接收訊息

阿新 • • 發佈：2019-02-08
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING/DTD BEAN/EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
  <bean id="jmsConnectionFactory"
    class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName">
      <value
>jms/Ntelagent/RequestQCF</value>
    </property>
  </bean>
  <bean id="destination"
    class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName">
      <value>jms/Ntelagent/RequestQ</value>
    </property>
  </bean>  
  
   <bean 
id="jmsConnectionFactoryForReceive"
    class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName">
      <value>jms/Ntelagent/ResponseQCF</value>
    </property>
  </bean> 
  <bean id="destinationForReceive"
    class="org.springframework.jndi.JndiObjectFactoryBean"
>
    <property name="jndiName">
      <value>jms/Ntelagent/ResponseQ</value>
    </property>
  </bean>


  <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate102">
    <property name="connectionFactory">
      <ref bean="jmsConnectionFactory"/>
    </property>
    <property name="defaultDestination">
      <ref bean="destination"/>
    </property>
    <property name="messageConverter">
      <ref bean="jmsTrxConverter"/>
    </property>
    <property name="receiveTimeout">
     <value>1</value>
    </property>
  </bean>
  
    <bean id="jmsTemplateForReceive" class="org.springframework.jms.core.JmsTemplate102">
    <property name="connectionFactory">
      <ref bean="jmsConnectionFactoryForReceive"/>
    </property>
    <property name="defaultDestination">
      <ref bean="destinationForReceive"/>
    </property>
    <property name="messageConverter">
      <ref bean="jmsTrxConverter"/>
    </property>
    <property name="receiveTimeout">
     <value>1</value>
    </property>
  </bean>
  
  <bean id="jmsTrxConverter" class="co.transport.jms.JmsTransactionConverter">
     <property name="rspQueue">
      <ref bean="destinationForReceive"/>
    </property>  
  </bean>
  
  <bean id="jmsRequestTransport" class="co.transport.jms.JmsRequestTransport">
    <property name="jmsTemplate">
      <ref bean="jmsTemplate"/>
    </property>
    <property name="jmsTemplateForReceive">
      <ref bean="jmsTemplateForReceive"/>
    </property>    
  </bean>

</beans>

相關推薦

spring的jms:用spring的JmsTemplate傳送和接收訊息

<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE beans PUBLIC "-//SPRING/DTD BEAN/EN" "http://www.springframework.org/dtd/spring-beans.dtd"><

利用API傳送和接收訊息，本程式碼測試全通過

~_~一個程式設計師的淘寶店： 點選開啟連結 using System; using System.Collections.Generic; using System.Text; using System.Runtime.InteropServices; namespace Set

java呼叫rabbitmq訊息佇列傳送和接收訊息例項

消費者Consumer.java程式碼 package com.rabbitMQ.pro; import com.rabbitmq.client.ConnectionFactory; impor

C#傳送和接收訊息

using System; using System.Collections.Generic; using System.Linq; using System.Runtime.InteropServices; using System.Text; using S

Spring整合JMS、IBM MQ傳送和接收訊息

最近才接觸到MQ，由於之前完全不知道是幹嘛用的，還是很花了一點時間研究的~先來簡單解釋一下名詞啦 一、名詞解釋 MQ MQ（message queue）指訊息佇列，是應用程式對應用程式的通訊方法。可以利用訊息佇列暫存資料報文。 MQ的原理其實就是生產者

《商城專案06》--用ActiveMQ實現訊息的傳送和接收

一, 使用場景 對商品資訊進行操作的同時, 將資料同步到solr庫, 實現該需求有以下幾種方式： 方式1: 在e3-manager-service新增商品資訊的實現類中直接寫將資料新增到solr庫; <弊端: 負責商品資訊操作的開發人員不一定對solr熟悉, 所以得分離出來寫, 這裡可

用PHP嘗試RabbitMQ（amqp擴充套件）實現訊息的傳送和接收

j教程： http://my.oschina.net/yuansir/blog/135226 消費者：接收訊息 邏輯： 建立連線-->建立channel-->建立交換機-->建立佇列-->繫結交換機/佇列/路由鍵-->接收訊息 <?

【Java TCP/IP Socket程式設計】----傳送和接收資料----構建和解析協議訊息

--------筆記來自於書籍《Java TCP/IP Socket程式設計》。 簡介 使用套接字時，通常要麼是需要同時建立通訊通道兩端的程式，要麼實現一個給定的協議進行通訊。如果知道通訊雙方都使用java實現，且擁有對協議的完全控制權，那麼就可以使用Java的內建工具如Serialiabl

【Java TCP/IP Socket程式設計】----傳送和接收資料----訊息成幀與解析

目錄   簡介 成幀與解析 成幀技術案例 簡介 在程式中使用套接字向其他程式提供資訊或者使用其他程式提供的資訊，這就需要任何需要交換資訊的程式間在資訊編碼方式上達成共識（包含了資訊交換的形式和意義），稱為協議，用來實現特定的應用程式的協議叫應用程式協議。大部分應

用C寫一個UDP傳送和接收程式

1、UDP網路程式設計主要流程 UDP協議的程式設計框架，客戶端和伺服器之間的差別在於伺服器必須使用bind()函式來繫結偵聽的本地UDP埠，而客戶端則可以不進行繫結，直接傳送到伺服器地址的某個埠地址。框圖如圖1.3所示 UDP協議的伺服器端流程 伺服器流程主要分為下述6個部分，即建立套

ROS 用 roboware實現節點資訊傳送和接收

在ros下實現節點程式設計，實現一個節點發送訊息，另一個節點接收。實現方式有多種，可以直接在命令視窗建立工作空間包以及節點，用catkin_make進行編譯，新增.bash路徑，然後執行rosrun  package  node_name 。這種方式對於一個ROS初學者來說容易出錯，而且很多網上的教程中出現了

RabbitMQ與SpringMVC整合並實現傳送訊息和接收訊息（持久化）方案二

   RabbitMQ的大約的介紹，上一篇已經有介紹了，這篇不介紹，直接描述RabbitMQ與SpringMVC整合並實現傳送訊息和接收訊息（持久化）。  使用了Spring-rabbit 傳送訊息和接收訊息，我們使用的Maven來管理Jar包，在Maven的pom.xml

java實現kafka訊息傳送和接收

之前寫了一篇關於kafka叢集搭建的點選開啟連結。想了解的可以看下。今天這個實現是和前面叢集對應的。使用的是新版的API。屬性如果想定製自己的，需要到官方網址上面去檢視一下對應的值。推介大家多去看看官方的介紹和demo。網上有些翻譯過來的例子並不完善，最好是知己知彼，才能百戰

linux高階訊號傳送和接收（附帶訊息）

高階訊號傳送和接收  sigaction   1.可以讓訊號處理函式遮蔽訊號集   2.可以讓訊號處理函式在訊號響應的同時接收訊號源程序資訊和附帶訊息。  sigqueue   可以傳送訊號並同時傳送附帶訊息。   使用kill函式傳送訊號，sigaction可以接收到訊號

java操作kafka傳送訊息和接收訊息

<!-- java程式的Kakfa-->    <dependency>      <groupId>org.apache.kafka</groupId>

Android中基於ServerSocket的實際使用與簡單介紹（內附一個PC端群控多臺手機的訊息傳送和接收Demo）

一、要想將ServerSocket整明白首先至少先要知道或是瞭解幾點基礎內容部分（大神或是有一定能力的小神跳過）： 1.ServerSocket是需要在服務端定義書寫的而在客戶端不需要ServerSocket，客戶端只需要建立socket就可以了。 2.socket需要在子

Java socket模擬傳送和接收HTTP訊息

理解：模擬登陸指定網站，登陸成功後，獲取返回串中的cookie值用於發起下次請求。 package demo.http.client; import java.io.IOException; import java.io.InputStream; import java.

用httpPost對JSON傳送和接收的例子

{        // 將JSON進行UTF-8編碼,以便傳輸中文        String encoderJson = URLEncoder.encode(json, HTTP.UTF_8);                DefaultHttpClient httpClient = new Defaul

JMS訊息傳送和接收例項

傳送訊息 不管是將訊息傳送到佇列還是釋出到主題，程式設計的步驟是相同的，差別在於使用不同的JMS物件。具體定義見表： 傳送訊息的過程大體分為以下幾步; 1、獲得一個Weblogic Server上下文的引用； 2、建立連線工廠； 3、使用連線工廠建立一個連線； 4、使用連

解決Springboot整合ActiveMQ傳送和接收topic訊息的問題

環境搭建 1.建立maven專案(jar) 2.pom.xml新增依賴 <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-bo