amqp

1熱度

1回答

我嘗試使用Azure服務總線和Apache Qpid和Spring與事務集成。但似乎Azure服務總線AMQP實現不支持事務。這是真的嗎？我沒有找到相關信息。這是我的JMS配置 <bean id="serviceBusConnectionFactory" class="org.apache.qpid.jms.JmsConnectionFactory"> <constructor-ar

0熱度

1回答

Spring Amqp：getRequiredQueueNames方法的用途

什麼是real的用途protected String[] AbstractMessageListenerContainer #getRequiredQueueNames()方法。是否爲重載時自定義SimpleMessageListenerContainer隊列名稱解析？

3熱度

1回答

我應該如何構造碼頭化的RabbitMQ？

我想我們的單片PHP的Symfony應用程序遷移到與碼頭工人一個較爲靈活的解決方案。應用程序和RabbitMQ之間有一些通信，我使用docker-compose將所有容器都放到了上面，在這裏是應用程序和RabbitMQ服務器。有很多圍繞着話題的討論是一個容器應產卵只有一個進程，而Docker best practices是有些含糊關於這一點：雖然這個口頭禪本意是好的，它不一定是正確的那每個容

0熱度

1回答

python_qpid_proton for mac使用amqps

我想在Mac OS X El Capitan上安裝python_qpid_proton，並且在實際建立連接時無法找到SSL庫。當試圖利用圖書館，我得到這個錯誤嘗試使用amqps連接：使用最新版本的自制軟件的 proton.SSLUnavailable: amqps: SSL libraries not found 我已經安裝OpenSSL和有這在我的.bashrc文件： export LDF

1熱度

1回答

AMQP | RabbitMQ |爲什麼他們有Fanout交換時，可以通過直接交換實現同樣的路由密鑰的多個隊列？

AMQP/RabbitMQ的新手。試圖理解這些概念/原理，並且偶然發現了這一點。以下兩種範例有什麼區別？扇出交換： FanoutExchange - >隊列1（路由鍵1），隊列2（路由鍵1）， VS 直接交換： DirectExchange - >隊列1（路由Key 1），Queue2（Routing Key 1），兩者都不能達到相同的效果嗎？如果不是的話，請問有人能說明它是如何不同的，以

2熱度

1回答

在哪裏設置交換和隊列（生產者與消費者）的綁定？

所有official RabbitMQ examples在消費者中設置隊列和綁定。該Publish/Subscribe tutorial指出，如果沒有隊列綁定到交換尚未的消息將丟失，但是這沒關係我們;如果沒有消費者正在收聽，我們可以放心地丟棄消息。這對我來說絕對不行，因爲我在RabbitMQ之上實現了一個工作員隊列，當消費者還沒有運行時，不丟失任何消息是很重要的。因此，我正在考慮在生產者中建

2熱度

2回答

RabbitMQ的水管壞了錯誤或丟失的郵件

使用鼠圖書館的BlockingConnection連接到RabbitMQ的，發佈消息時，我偶爾會得到一個錯誤： Fatal Socket Error: error(32, 'Broken pipe') 這是一個非常簡單的子過程，出需要的一些信息內存中的隊列，併發送一個小的JSON消息到AMQP中。只有當系統幾分鐘內沒有發送任何消息時，錯誤纔會出現。設置： connection = pika.Bl

3熱度

1回答

單個隊列，多@RabbitListener但不同的服務

是否有可能有一個@RabbitListener，如： @RabbitListener(queues = STORAGE_REQUEST_QUEUE_NAME) public FindApplicationByIdResponse findApplicationById(FindApplicationByIdRequest request) { return repository.fin

0熱度

1回答

如果處理失敗，Rabbitmq將消息移動到不同的隊列

我正在使用RabbitMq .net和消息確認。如果消費者能夠處理該消息，我們可以以 channel.BasicAck(ea.DeliveryTag, false); 的形式發回確認，這將使其脫離隊列。我想將郵件移動到「錯誤隊列」如果我有 var message = JsonConvert.DeserializeObject<object>(json); 我一直在使用「X-死信交換」試圖與

0熱度

1回答

Spring集成處理程序錯誤 - >確認 - 確認通道

我想做的事：從Web服務接收消息發送XML消息兔驗證XML爲xsd - >啓動異常（驗證不正確的）返回定製錯誤消息發送到web服務步驟1：接收從web服務消息 - > RESULT行 <ws:inbound-gateway id="ws-inbound-gateway" request-channel="requestChannel" reply-channel="reply