spring-rabbitmq

1熱度

1回答

我需要設置keepalive端點以便可以web應用程序（tomcat war）。我的WAF會定期採樣終點，以確保應用程序健康。健康應用程序意味着應用程序已啓動，並且與RabbitMQ服務器（版本3.5.3/spring-rabbit 1.4.5）的通信已啓動並且功能正常。我會打開一些REST API到我的WAF來驗證連接狀態。閱讀文檔我很遺憾如何實現這個功能。我注意到一些功能，可以幫助，

0熱度

1回答

在調用onMessage之前添加默認方法，如果MessageListener是Spring Amqp

我需要添加一些默認功能，它會在調用實現類的onMessage函數之前從Spring Amqp的Message頭中選擇一些值。例如 class TestListener implements MessageListerner { public void onMessage(Message message){ // some logic } } 從上面的例子，我需要使用消息對象

0熱度

2回答

春AMQP註釋基於

我是新來春AMQP並希望使用基於註解的配置使用最新的Spring AMQP 1.5.4生產者和消費者，是否有可供配置的任何pseoudo代碼做的邏輯創建連接或@Queue等。

2熱度

1回答

配置服務器與RabbitMQ的連接問題

我的RabbitMQ Cloud Foundry中運行，並試圖從本地運行配置服務器連接，下面是application.yml文件中配置什麼 spring rabbitmq: host: xxxx vhost: xxxx port: 5672 username: xxx password: xxx 拋出啓動時的異常以下 or

1熱度

2回答

SimpleMessageListenerContainer一樣 - 消費引發的異常，如果連接工廠支持它

我不斷收到在我的春天RabbitMQ的消費方以下警告處理可以重新啓動。它一直在尋找重新啓動。 [SimpleAsyncTaskExecutor-3317] WARN org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - Consumer raised exception, processing can r

0熱度

1回答

無法爲推送通知啓用/監控彈簧雲總線端點

我配置了spring cloud config以從git存儲庫讀取屬性。對於當前實現，如果配置發生更改，如果發佈到/ refresh on我的客戶我能夠看到更新的屬性。現在，我想使用spring-cloud-bus-monitor來檢測我的git repo中的更改並自動刷新客戶端端點中的屬性。即使在依賴關係中添加spring-cloud-config-monitor之後，/ monitor端點也未

0熱度

1回答

在RabbitMQ中注入服務 - ConfirmCallback類不起作用

我創建了一個實現ConfirmCallback接口的獨立回調類，並重寫了confirm（）。相關數據和確認工作正常。但是我已經使用@Autowired注入了一個服務，以便在成功從rabbitMQ獲得ack後執行其他一些活動。但該服務引用根本不被注入。我已經在其他工作正常的類中注入了相同的服務。我的代碼 public MyConfirmCallback implements ConfirmCallb

1熱度

1回答

春天的RabbitMQ匿名隊列

是新來的彈簧rabbitMQ.I有以下如果沒猜錯question..Please正確：我有申請即三個實例。的Instance1 實例2 Instance3 注意：這些情況下不需要固定number.All這些情況下聽實例的數量是不固定的同一exchange..As，我的要求是相同的消息shuld是接收所有三/（數量可以）變量..如何實現這一點使用春天amqp 如果聲明隊列名稱並綁定交換消息將

0熱度

1回答

RabbitMQ配置腳本

我有一個兔子配置文件，它包含一個JSON。據我所知，通過使用我可以配置RabbitMQ，但我不知道我必須把該文件或如何運行它。 { "rabbit_version": "3.5.6", "users": [{ "name": "guest", "password_hash": "GAd/n+dflOQhAEnqkF6y2V0TMrU=",

0熱度

1回答

SimpleMessageListenerContainer一樣回採後無法恢復

當某個事件到來時，我停止我的rabbitmq listner使用container.stop();和必要的工作完成後，我重新啓動它與container.start()，但是，當一個新的事件到來時，我得到以下錯誤： Exception in thread "SimpleAsyncTaskExecutor-1" 2016-04-22T16:20:53.646 WARN 15336 --- [cTask