spring-jms

0熱度

1回答

我計劃有一個經紀人主題，並有多個默認消息偵聽器或簡單的消息偵聽器。所有的監聽者都執行相同的代碼。是否每個偵聽器代碼執行獨立於另一個偵聽器。我想問的是，如果訪問相同方法時聽衆之間會有衝突嗎？我有點像多線程執行一樣工作。我正在使用JMS和activemq作爲代理。需要了解的一些代碼：每個偵聽器都會調用這個方法來發送事件的「事件處理」。該方法將依次調用其他方法。句柄方法將依次調用其他方法。 p

0熱度

1回答

JMSListener選擇器不工作

我有一個JMS生產者發送2種消息：業務邏輯和心跳信息。目前，兩者都由同一個接收器處理，但我現在正在嘗試通過使用選擇器爲每個接收器分配專用類。我遇到的問題是每當將選擇器添加到接收器時，它都會停止接收消息。這是我到目前爲止。爲簡單起見，我只增加了心臟的跳動代碼：要發送信息，我有這樣的： private void sendHeartBeat() { this.buildTemplate().

0熱度

1回答

JMS連接在發送消息給未授權的路由時不拋出JMSSecurityException

我使用Apache Camel和Spring從我的Java服務發送消息。如果在交換時發生任何錯誤，我需要處理/觸發某些事件。我正在使用下面的代碼來實現我的目標。 try { producerTemplate.sendBody(endPoint, bytes); } catch (final RuntimeCamelException exception)

2熱度

2回答

當JMS偵聽器發生異常時會發生什麼

我正在使用默認消息偵聽器容器。我在配置中將會話事務屬性設置爲true。我onMessage()方法是這樣的： public void onMessage(Message message) { try { // Some code here } catch (JmsException jmse) { log.error(jmse); } cat

0熱度

1回答

耐用偵聽器/消費者的使用案例場景

因此，我正在爲一個主題（即多個偵聽器）創建併發使用者。我將它們配置爲耐用。 @Bean public DefaultMessageListenerContainer listenerContainers() { DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();

2熱度

1回答

更改Sprint啓動中嵌入式ActiveMQ的活動MQ RedeliveryPolicy

如何在使用Spring Boot時更改嵌入式ActiveMQ的交付策略？我試着在DefaultJmsListenerContainerFactory上指定FixedBackOff，但它沒有幫助。下面是我用來初始化jms工廠bean的代碼。我有一個消息使用者正在處理隊列中的傳入消息。在處理期間由於不可用的資源，我拋出一個檢查異常。我希望在固定的時間間隔後重新傳遞消息進行處理。春季啓動：1.5.7.

-1熱度

1回答

Spring 4.x的最穩定版本。升級需要從3.0.5

我想升級我的應用程序從春季3.0.5版本到春季4.x版本，我想知道哪一個是最穩定的（沒有錯誤）..感謝您的幫助：）我想知道我們應該用於升級的主版本和次版本嗎？

0熱度

1回答

MessageConversionException的通用處理程序

我想在隊列中具有特定格式並可以反序列化到某個Java類時處理隊列中的消息。爲了做到這一點，我創建了以下方法。 @JmsListener(destination = "myQueue", containerFactory = "myFactory") public void receiveMessage(Message message) { service.process(message

0熱度

1回答

如何從春監聽

得到消息ID我有以下代碼： @JmsListener(destination = "myQueue", containerFactory = "myFactory") public void receiveMessage(MyClass message) { service.process(message); } 現在，我想獲得的JMS消息ID。我知道我可以重寫MappingJa

1熱度

1回答

如何從兩個不同的連接工廠加入Spring JMS事務？

我正在使用不同的連接工廠來發送和接收消息，在部分提交問題中遇到了發送失敗的問題。 jms:message-driven-channel-adapter使用receiveConnectionFactory ro從隊列中接收消息。 jms:outbound-channel-adapter使用deliverConnectionFactory將消息發送到下游隊列。我們只有一個JmsTransactionM