spring-amqp

0熱度

1回答

Spring AMQP優點/缺點使用SimpleMessageListenerContainer覆蓋從隊列接收消息

我想知道使用SimpleMessageListenerContainer過度使用Spring AMQP手動接收消息的優缺點。另一個問題是，當我們創建SimpleMessageListenerContainer設置隊列，rabbitmq是否調用listeneradaptor或者SimpleMessageListenerContainer是否繼續輪詢隊列以檢查消息並在消息是消息時調用已註冊的適配器。

1熱度

1回答

隊列恢復後的綁定重新聲明

我目前正在開發一個rabbit-amqp實現項目，並使用 spring-rabbit以編程方式設置我所有的隊列，綁定和交換。我想，如果它被刪除重新創建隊列，發現引用文檔中的以下內容：引進了許多改進的處理 3.14偵聽容器隊列 1.3版偵聽器容器中有多個隊列。該容器必須配置爲偵聽至少一個隊列;這也是以前的情況，但是現在可以在運行時添加和刪除隊列。當任何預取消息已被處理時，容器將回收（取消並重新

7熱度

1回答

動態添加新的隊列，綁定和交換爲豆

我目前正在研究一個rabbit-amqp實現項目，並使用spring-rabbit以編程方式設置我所有的隊列，綁定和交換。（spring-rabbit-1.3.4和spring-framework版本3.2.0）在我認爲聲明中，javaconfiguration類或基於xml配置的聲明都是相當靜態的。我知道如何設置一個更加動態的數值爲隊列，交換或類似這樣的結合（前名）： @Configura

0熱度

1回答

兔子如何自動檢查消費者是否仍然可用，如果不從列表中刪除它？

初始狀態：兔子已經一個消費者連接到它事件：兔子和消費者之間網絡連接打破結果：消費者嘗試重新連接兔子，但兔子有消費者在它的消費清單下一個事件：網絡連接重新啓動，消費者重新連接到兔子，但以前的兔子連接不會消失。結果：兔試圖發送消息到不活動的消費者問：是否有任何機會，以兔自動檢查，如果消費者仍然可用，如果沒有 - 從列表中刪除嗎？請注意，心跳選項已打開，但並未解決問題。 conn

0熱度

1回答

Rabbit MQ同步在多線程應用程序中發送和接收

我有一個多線程的彈簧應用程序，我在這裏創建主題交換，聲明隊列，用路由鍵綁定它們。同步發送和接收消息。我能夠將消息發送到話題交換，並查看使用routingKey將消息發佈到隊列中。但是，在收到消息時，我看到消費者在每次迭代中都註冊了隊列，並且沒有取消註冊。我正在創建QueueingConsumer接收郵件，可能有另一種方法可以做同樣的事情，請讓我知道。下面是receiveMessage方法的片段。

1熱度

1回答

與兔AMQP的Spring集成「客戶端發送郵件 - >服務器接收與在返回隊列返回味精 - >客戶端得到相關消息」

我能夠用兔的Java API的做寫Java程序如下：客戶端發送消息在兔MQ交換/隊列相關性id（說UUID - 「348a07f5-8342-45ed-b40b-d44bfd9c4dde」）。服務器接收該消息。服務器通過具有相同關聯Id的Rabbit MQ交換機/隊列發送響應消息 - 「348a07f5-8342-45ed-b40b-d44bfd9c4dde」。客戶端接收到的相關的消息僅在

0熱度

1回答

使用ids添加多個偵聽器容器似乎不起作用

我有一個rabbitMQ配置，其中需要有兩個單獨的偵聽器容器，每個容器都有一組偵聽器。下面是從的RabbitMQ-context.xml的一個片段： <rabbit:listener-container connection-factory="connectionFactory" message-converter="jsonMessageConverter" auto-startup="tr

1熱度

1回答

Spring-AMQP RPC容器

在spring-amqp上存在一個支持回覆功能的容器？我想讓RPC像https://www.rabbitmq.com/tutorials/tutorial-six-java.html，但使用spring-amqp。

0熱度

1回答

如何在Spring amqp中使用MessageListenerAdapter將消息類型參數與pojo一起使用？

我得到異常 Caused by: java.lang.NoSuchMethodException: com.stockopedia.symfony.Foundation.importExchange([B) at java.lang.Class.getMethod(Class.java:1665) at org.springframework.util.MethodInvoke

1熱度

1回答

如何使用Spring AMQP接收來自RabbitMQ的correlationid消息

我經歷了RabbitTemplate的API。它只提供從隊列中獲取消息的接收方法。但是，無法通過特定的相關ID獲取消息。你能幫我理解我在這裏錯過了什麼嗎？目前，我使用ActiveMQ的JMS API來使用以下代碼來接收消息，其中createConsumer帶有消息選擇器。展望與RabbitMQ的做同樣的使用Spring AMQP： private ObjectMessage receiveMes