jmstemplate

0熱度

2回答

我通過org.springframework.jms.core.JmsTemplate將org.springframework.messaging.support.GenericMessage發送到ActiveMQ中的隊列。在ActiveMQ中，我看到這條消息： Cannot display ObjectMessage body. Reason: Failed to build body from

1熱度

1回答

春天批量寫入ActiveMQ

我嘗試將消息寫入JMS隊列，我在下一步中將其寫入數據庫。第一部分應該是第二個異步同步。 JMS部分非常慢（1分鐘內1100個項目到隊列中）。這就是我的工作。 @Bean public Job multiThreadedStepJob() { Flow flow1 = new FlowBuilder<Flow>("subflow1").from(step()).end();

0熱度

1回答

春JMS到WebSphere MQ連接錯誤

AppConfig.xml設置： <bean id="connectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory"> <property name="hostName" value="abchost.com /> <property name="port" value="1414" /> <property name="

1熱度

1回答

使用Spring JmsTemplate的/ ActiveMQ的使用請求/應答，而不在隊列中

阻止了其他郵件，我們實施了，我們要等待響應特定的用例分佈式請求/響應類型的架構。我們使用的JMS代理是ActiveMq，代碼使用Spring連接在一起。我們看到的問題是，它看來，如果發送了一堆請求到相同的目的地，任何請求，比如，需要的時間顯著量來完成，塊跟在它後面的請求消息。消費者使用的SessionAwareMessageListener接口僅支持onMessage（）方法。在這裏實現並行性的

0熱度

3回答

如何從JMS隊列中刪除消息？

我有幾個作業，每個作業都有多個排隊的消息。每個作業的消息是隨機交錯的。如果用戶決定取消作業，我想從隊列中刪除屬於該作業一部分的所有消息。我已經能夠使用browse()找到所有要刪除的郵件，但一直未能弄清楚如何刪除它們。我試圖通過使用receiveSelected()擺脫他們，但它只是掛起。（我正在使用JmsTemplate）

2熱度

1回答

Setsessiontransacted如何在JMSTemplate和DefaultMessageListenerContainer與Pub /子模型中工作

我正在使用發佈者/訂閱者模型，在該模型中使用JMSTemplate將消息發佈到主題上。我使用defaultmessagelistenercontainer來訂閱和接收消息。我知道我可以在兩個配置中設置sessionTransacted true。但如果我把會發生什麼情況1）只有JMSTemplate setsessionTransacted爲true？ 2）only messagelisten

1熱度

1回答

Spring JMS和參數化類型（@JmsListener，例如列表<String>參數）？

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

0熱度

1回答

在一個事務中發送多個jms消息

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

0熱度

1回答

如何使用JMS將預定消息發送到Azure服務總線

Azure服務總線能夠發送預定消息。用此處描述的AMQP協議發送計劃消息：https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-amqp-request-response#message-operations 計劃消息。請求該請求消息必須包括以下應用程序屬性： | Key |值|類型|必需|價值內容

0熱度

1回答

控制消息偵聽器停止爲一定時期並重新開始聽

監聽器： <bean id="msglistenerForAuditEvent" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory" ref="jmsFactory"/> <property name="ses