spring-rabbit

0熱度

1回答

我有一個Rabbitmq集羣設置（沒有HA）。我的客戶是Spring應用程序，它提供了一個開箱即用的故障轉移機制，它連接到下一個可用節點。由於隊列沒有鏡像，因此如果我預先聲明隊列，並且當第一個節點關閉時，連接將建立到第二個節點，那麼是否可以。這有意義嗎？另一個問題，可以說我有一個負載平衡頂部的Rabbitmq羣集。我的應用程序使用負載平衡連接。將隊列在所有節點上聲明還是將根據LB的路由策略在節

0熱度

1回答

Rabbitmq ready和unack消息

我有一個擁有50個消費者的隊列，預取計數爲100左右。所有消費者都來自單個JVM實例。所以，當應用程序關閉時，消息處於READY狀態。處於就緒狀態的消息數量等於（prefetch_count *消費者數量）。現在的問題是，在READY狀態下的消息會發生什麼？它會重新遞交還是會死信？

0熱度

1回答

自定義配置沒有得到反映在applicationcontext.xml

我使用自定義配置爲我的RabbitMQ連接。我正在連接到多個主機。 <context:property-placeholder location="classpath:/test_setting.properties" ignore-unresolvable="true"/> ... <rabbit:connection-factory id="testConnectionFactory"

1熱度

1回答

哪個更好CachingConnectionFactory.CacheMode連接或頻道在春節AMQP

您好我一直在使用Spring AMQP與CachingConnectionFactory得到的連接與被顯示在下面 <bean id="connectionFactory" class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory"> <constructor-arg value="rab

0熱度

1回答

異步與Spring引導和RabbitMQ的

請求 - 應答我們要實現以下情形：生產者服務發送一些輸入PARAMS到另一個服務要求基於這些PARAMS的細節。生產者想要指定隊列將在哪裏偵聽答覆。此外，生產者希望提供一些元數據，以便它可以將它發送的參數與其獲得的結果相關聯。請指教如何正確地做到這一點。

1熱度

1回答

如果隊列不存在，則消息丟失

當我們將消息發送到RabbitMQ並且隊列不存在時，消息丟失而不會引發任何錯誤。郵件將發佈到哪裏？死隊？

0熱度

1回答

的情況下，代理連接彈簧AMQP的消息彈性下降

我有管理的春天AMQP客戶端消息彈性的使用案例中的RabbitMQ服務器連接下來的情況下，因爲我已經使用過Spring重試 RabbitTemplate template = // get template from some bean RetryTemplate retryTemplate = new RetryTemplate(); ExponentialBackOffPolicy ba

1熱度

1回答

Spring Cloud Stream Rabbit交付確認

如何確保Spring Cloud Stream Rabbit保證交付。我的代碼如下： - class Source { MessageChannel output; Repository repo; @Transactional void publisher(Command command){ repo.save(command);

1熱度

1回答

Spring Integration AMQP - 消息偶爾消失，需要超時？

我有一個入站的RabbitMQ通道適配器，每天成功處理3000條消息，但偶爾我會在RabbitMQ管理控制檯中看到一條未消息的消息數爲1。這似乎仍然是這樣。我確實有一個重試嘗試建議鏈重新嘗試3次，然後通過死信路由鍵移動到DLQ，這對大多數異常都能正常工作。在過去的幾個星期裏，沒有發生的事情發生了兩次，並且在其中一次我能夠接受線程轉儲，並看到int-http：outbound-gateway調用

0熱度

2回答

Spring AMQP監聽器超時

我有處理SpringAMQP監聽器超時能力的要求，即我們從生產者發送消息，Spring AMQP的消費者監聽器線程接收到消息但說需要很多時間來執行自己並掛起，最終導致Listener線程無法使用。那麼，有沒有辦法，我們必須由Spring AMQP提供任何消費超時設置讓聽者線程被釋放再次給定的超時時間