message-listener

2熱度

1回答

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

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

0熱度

1回答

ActiveMQ的故障轉移

代理網址 failover:(tcp://broker1:61616,tcp://broker2:61616)?randomize=false&jms.useAsyncSend=false&jms.dispatchAsync=false&maxReconnectAttempts=2&maxReconnectDelay=100 我註冊的活躍代理的消息監聽器中保存消費者第二個經紀人。你能給我點亮嗎

0熱度

1回答

是MessageDrivenContext.setRollbackOnly（）需要隊列的放置權限

當我們使用MessageDrivenContext.setRollbackOnly()時，Container會回滾交易競賽，所以郵件會被放回隊列JMS。是否需要明確的看跌許可該隊列或作爲其交易水平，使容器將處理它沒有明確的看跌許可。我使用IBM MQ。

1熱度

1回答

使用JMS選擇器與內存中的過濾

我有一個需求來讀取隊列中的消息，通過虛擬主題進行填充。考慮讓JMS選擇器只讀取我在偵聽器中需要的消息 - 但由於我不想讓消息進入隊列 - 我可以實現另一個偵聽器，它可以讀取剩餘的消息並只是確認它，或者我可以做一個單獨的監聽器，它沒有JMS選擇器，但在內存中進行過濾。建議採用哪種方法？

0熱度

1回答

[RabbitMQ] [Spring]如何獲取最終交換名稱？

對於Exchange與Exchange的結合definintion public class RabbitRecieveTest implements MessageListener { @Override public void onMessage(Message message) { String firstExchange = message.getMessagePro

1熱度

1回答

Spring AMQP對消息超時採取行動

我正在使用Spring AMQP進行異步消息傳遞。我的模型假定有兩個應用程序A和B，都是生產者和消費者。 A向B發送工作請求並開始監聽。 B正在監聽作業請求，並且當作業完成時，啓動作業並定期向A發送進度消息。 B在作業完成後向作業完成消息發送作業完成消息。 A消耗進度消息，直到工作完成消息到來，然後A存在。我在課程級別上使用@RabbitListener，在方法級別上使用@RabbitHandl

1熱度

2回答

使用MessageListener的JMS MessageConsumer在ActiveMQ關閉時終止

嘗試讓JMS MessageConsumer在ActiveMQ重新啓動後繼續存在，因此可以使用故障切換傳輸協議重新連接。但是，它會在ActiveMQ關閉時終止。這看起來像報道和「解決」的錯誤，但我仍然在ActiveMQ中5.10.0的最新版本看到這我用下面的行家依賴 <dependency> <groupId>org.apache.activemq</groupId>

1熱度

1回答

JMS：可以是MessageListener的onMessage中的消息null？

如果我的MessageConsumer正在實現MessageListener（JBoss JMS 1.1 API），是否有消息可能在Method onMessage（消息）中爲空的情況？ import javax.jms.MapMessage; import javax.jms.Message; import javax.jms.MessageListener; @MessageDriv

0熱度

1回答

限制時間，在此期間從JMS隊列讀

我具有以下設置：外部應用寫入到JMS隊列 JMS隊列也是外部，所以沒有配置可能這裏使用ActiveMQ在Glassfish上運行的現有應用程序將服務器連接到jms隊列現有應用程序是一個實現MessageListener接口的MessageDriven bean（當它們被放入隊列時正在處理消息）新要求說，這些消息只能從02:00時間框架內進行處理，以04:00 我最好如何限制了Message

0熱度

1回答

DMLC消息消耗和確認

這是Difference between AUTO_ACKNOWLEDGEMENT mode with and without Spring JMS的後續問題。我正在使用DMLC，並且我的併發使用者數爲1.預取限制爲> 1.我收到消息並在偵聽器執行之前進行確認。所以，當偵聽器正在執行時，代理具有更多的消息，並按照預取設置將消息發送給使用者。由於聽衆仍在執行，消費和確認如何對後續消息起作用？是否