spring-jms

    0熱度

    2回答

    我正在使用Spring集成JMS出站適配器向IBM MQ發送消息,並且發現來自上游應用程序的一些JMS標頭被遺漏或默認。上游應用程序發送所述下面JMS頭, 的JMSType: JMSDeliveryMode: JMSExpiration: JMSPriority: JMSMessageID按: JMSTimestamp: JMSCorrelationID: JMSDestination: JMSR

    1熱度

    1回答

    我希望能夠發送List<String>類型的值使用JmsTemplate.convertAndSent(...),然後使用註釋爲@JmsListener的方法接收它,該方法採用類型爲List<String>的參數。 但是,似乎將消息有效內容類型存儲爲消息屬性的默認方法不支持泛型。 如果我期待在MappingJackson2MessageConverter.getJavaTypeForMessage

    0熱度

    1回答

    我必須向2個不同的隊列(隊列1和隊列2)發送消息。但是,我想回滾,如果發送失敗的任何隊列(隊列1或隊列2)。 我的源代碼如下所示。任何人都可以通過這方面的一些投入 public void sendMessage(final Map<String, String> mapMessage) { jmsTemplate.send(queue1, session -> { MapM

    2熱度

    1回答

    我期待@JmsListener會自動將json對象轉換爲我的對象,但它的有效負載是以json格式而不是實際對象的形式返回數據。 @JmsListener(destination = "${default-queue-name-to-listen}") public void receiveMessage(final Message<MyObject> message) throws JM

    1熱度

    1回答

    閱讀郵件我試圖創建一個使用使用DefaultMessageListenerContainer收聽來自IBM MQ消息一些春季啓動代碼。 我可以創建MQQueueConnectionFactory發送和接收使用JmsTemplate的消息,但是這是爲了通過高通量,要使用偵聽器,而不是投票。 我有很多整合的代碼到一個組件,所以我希望我所有的是相關的。 如果我安排receiveMessage方法,它拿起

    0熱度

    1回答

    當我以編程方式註冊JMS偵聽器端點時,我再也沒有事務性支持。 我使用TransactionAwareConnectionFactoryProxy與JDBC數據源和JMS,它提供像JTA一樣好的全局事務(1PC全局tx)。使用註釋,它工作得很好: @JmsListener(containerFactory = "jmsQueueListenerContainerFactory", destinati

    0熱度

    1回答

    我想創建一個使用Wicket 7和Spring boot 1.5.3作爲後端的通知面板。 對於通知我使用JMS和ActiveMQ與Spring啓動JMS with Spring Boot。 我的問題是如何自動刷新(重新呈現/更新)檢票器組件一旦從我的JMS偵聽器發來一條消息。

    0熱度

    1回答

    我有兩個Web應用程序並部署在同一個tomcat服務器中。我想從app1發送jms消息到app2。 我創建JMS連接工廠和生產使用APP1春天JMS(使用嵌入式活躍MQ代理網址爲VM://本地主機) 但是,當我創建APP 2的JMS客戶端,消費者是無法接受消息。 如何在app2 web應用程序中共享相同的工廠實例/隊列?我需要修改server.xml以共享conn工廠等嗎?

    0熱度

    1回答

    我有從tibco ems隊列中提取待處理消息的要求。以下是我使用spring jms模板的程序。但是,我發佈了5000條消息進行排隊,並嘗試提取相同的消費數量,並意識到花了將近20分鐘的時間瀏覽並獲取計數。請告知這裏的任何性能改進或任何其他更好的方式來獲得未決消息數 jmsTemplate.execute(new SessionCallback<QueueBrowser>() { pub

    0熱度

    1回答

    我創建了一個使用版本4.1.2.RELEASE的Spring JMS應用程序,該應用程序連接到運行ActiveMQ 5.11.0的代理。我看到的問題如下。在日誌中,我注意到每秒都會看到一個連接被創建爲這樣。 2017-06-21 13:10:21,046 | level = INFO | thread = ActiveMQ Task-1 | class = org.apache.activemq.