spring-jms

    2熱度

    1回答

    我有一個單一的「點對點」IBM MQ隊列接收來自多個生產者的消息。我的應用程序使用隊列中的消息。我使用Spring的JmsTemplate的」和‘使用DefaultMessageListenerContainer’異步消耗的消息。 我的應用程序是在2個JVM上運行,這意味着有每個JVM聽相同的隊列活動的2個監聽器。 來到我的問題,如果消息到達... 1)如何聽衆知道消息隊列中來了嗎? 2)出了兩個

    0熱度

    2回答

    我使用ActiveMQ(與Spring)發送消息到遠程OSGi-Container。 這工作得很好,但有一個問題。 我有兩個類實現Serializable。一類是另一類的類成員,如下所示: public class Member implements Serializble { private int someValue; private static final long serialVer

    1熱度

    1回答

    我想運行一個非常基本的應用程序來學習Spring JMS + ActiveMQ。我看到我的Producer創建了消息(sysout),但沒有在我的Consumer中顯示,也沒有拋出異常。我想我在這裏錯過了一些簡單的東西;非常感謝任何幫助。 [EDITED,下面的代碼工作] 製片: @Component public class JmsMessageProducer { @Autowi

    1熱度

    1回答

    我正在嘗試示例項目來實現Spring 3 + Active MQ Request/Response Synchronos ..我創建了彈簧配置文件,將消息放入隊列中的消息生產者以及消費消息並返回響應的消息生產者... 我正在得到響應...但我的示例程序看起來並沒有結束。 ..當我檢查Apache Active MQ管理控制檯時,我發現每次運行我的測試類時,用戶數都會繼續增加......我必須在ec

    1熱度

    2回答

    我想延遲某個時間的消息傳遞,這對於每個消息都是不同的。 我指的是weblogic 10.3 WLMessage documentation其中推薦使用javax.jms.Message.getIntProperty("JMS_BEA_DeliveryTime")。 但是我無法弄清楚如何將JMS_BEA_DeliveryTime設置爲INTEGER。我期待它是long。 我無法找到有關此屬性JMS_

    1熱度

    1回答

    我們在這個weblogic10.3.4和JMS隊列上建立了,下面是消息監聽器代碼,它使用Spring JMS,MessageProducer設置爲ClientAcknowledgeMode。當發生異常時,消息仍然被移出隊列並回滾,下面的代碼有什麼問題? public class EmailListener implements MessageListener,ExceptionListener{

    3熱度

    1回答

    我試圖設置Spring的DefaultMessageListenerContainer類,以在拋出異常或調用session.rollback()之後重新傳遞消息。我也試圖讓這個在glassfish 3.1.2 web profile上運行。 當我的SessionAwareMessageListener的onMessage()方法中調用session.rollback()時,我收到一條異常消息:Me

    1熱度

    1回答

    我試圖在tomee + 1.5.0中啓動網絡控制檯,如下所示: http://activemq.apache.org/web-console.html(使用Tomcat的示例配置) -Dcatalina.base = 「d:\套件\ Apache的tomee加1.5.0」 -Dcatalina.home =「d:\套件\ 我啓動服務器時使用下面的參數apache-tomee-plus-1.5.0「

    2熱度

    2回答

    爲了讓DefaultMessageListenerContainer控制事務,程序如何進行......據我所知,我只需要提供sessionTransacted屬性給DMLC。我的目標是把消息發回隊列中,如果一些錯誤occure ... 一直在尋找相當一段時間,但沒有發現任何東西...... 我的彈簧配置(它的一部分): <bean id="abstractMessageListenerContai

    0熱度

    1回答

    我怎樣才能確保兩個偵聽器容器: <bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="messageListener" ref="MessageListener" /> <propert