jms

0熱度

1回答

我正在使用spring-boot-starter-activemq和PoolFactory。一切都很好，通過application.yaml很容易配置，但我無法找到注入我的定製RedeliveryPolicy的正確方法。所以問題是我該怎麼做？

1熱度

1回答

模擬JMS MessageSource

我有一套MessageSource s（實際上JmsDestinationPollingSource s）這是定期輪詢。這是一個持久化隊列項目的Oracle AQ數據庫。 @Bean @InboundChannelAdapter(value = "queueSourceChannel", poller = @Poller(fixedDelay = "1000")) public Message

0熱度

3回答

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

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

1熱度

1回答

使用Alpakka顯式確認JMS

我目前使用Akka-Camel將基於Akka的應用程序與各種消息隊列集成在一起。現在我想升級到Akka的最新版本，我發現現在不推薦使用此集成。我嘗試過使用alpakka-jsm集成，但我無法查看在處理完消息後是否可以對消息隊列執行明確的ack。這個功能是否存在於這個新組件中？

0熱度

1回答

由於監聽器容器在此期間已被停止，因此拒絕收到的消息：

在我的JMS監聽器停止後，我一直在持續打印此異常打印。部署後兩天的日誌文件大約爲6.2GB。 2017-08-01 12:14:36.436 WARN 4456 --- [er (4102308050)] o.s.j.l.SimpleMessageListenerContainer : Rejecting received message because of the listener conta

0熱度

1回答

動態設置JMS選擇

我試圖創建一個以上的消費者和每一個剛收到1種類型的消息與消息定義的某些屬性：例如，message.setProperty("id","someId"); 我現在有對消費者設置選擇JmsListener問題： @JmsListener(destination = "OMP.DEVICES", containerFactory = "jmsListenerFactory", selector=som

0熱度

1回答

在RabbitMQ交易消費

我已經在RabbitMQ尚未新。我需要爲這些目的MOM系統：發行消息被消耗，直到我的邏輯執行成功。代理不必從隊列中刪除發佈的消息，直到我的邏輯成功執行。對於這些目標，我寫了下面的代碼在第一次嘗試： ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); Con

0熱度

1回答

從一個wildfly 10應用程序連接到另一個遠程JMS隊列時出現問題

我有兩個Wildfly 10服務器在運行，並且有一個JMS隊列與Jboss和Hornet一起工作。在那裏，我使用了netty連接器，所以我放棄了所有配置，並獲得了wildfy 10上的消息傳遞的默認配置。我無法讓JMS正常工作。我沒有真正找到任何我想要的文檔或示例。我希望有人能幫忙。 Serverside集團我已經設置了wildfly 10服務器上的服務器端使用獨立-full.xml得到消息的

0熱度

1回答

JMS傳遞失敗 - WebLogic Server上的錯誤目標

將消息放入錯誤隊列後，如何將此消息重新傳遞到原始隊列？是否需要創建一個MDB才能從錯誤隊列中獲取此消息並放在原始隊列或weblogic上有一些配置？

0熱度

2回答

使用Apache Artemis的JMS隊列，如何僅檢索隊列中的最後一條消息

我目前使用的是Artemis ActiveMQ 2.2.0並且使用隊列，我能夠發送和接收消息而沒有任何問題。但是，我想知道如果隊列中有多條消息，接收方只能檢索最後一條消息嗎？有我需要使用的特殊隊列嗎？謝謝，