message-queue

-1熱度

2回答

接收來自wildfly JMS隊列消息從wildfly JMS隊列接收消息時，我遇到了一個棘手的問題，我的代碼是打擊： Session produceSession = connectionFactory.createConnection().createSession(false, Session .CLIENT_ACKNOWLEDGE); Session con

0熱度

2回答

像RabbitMQ這樣的消息隊列是這個應用程序的理想解決方案嗎？

我一直在做一個基本上是電子商務的項目。這是一個多租戶應用程序，每個客戶都有自己的域名，網站根據客戶的配置進行自我調整。如果客戶端已經有一個像ERP那樣管理庫存的軟件，那麼我需要一個介質，當電子商務生成訂單時，可以通知像ERP這樣的外部應用程序發生這種情況應對措施。這就像在不同的應用程序中引發事件一樣。我想到了在數據庫中存儲這些事件，並具有客戶做出較短的時間間隔請求獲取數據，但一些有關輪詢和使用

0熱度

1回答

消息不會自動移動到死信通道（DLC） - 代理 - wso2 ei

我使用帶有Message Broker的WSO2 EI 6.1.1，並嘗試使用端點創建具有消息存儲和消息過程的消息隊列。當我關閉我的端點時，消息處理器被停用，消息保留在隊列中，並且它們不移動到DLC。我該怎麼做才能使它工作？感謝，瑞斯Shomou

1熱度

1回答

多主題消息隊列

我對微服務的體系結構有一個相當理論上的問題。假設我們有兩個通過RabbitMQ彼此交互的微服務A和B。當A有問題時，它會向queue_1發送消息，並通過queue_2接收來自B的答覆（因此通信可以保持異步）。 ------------ ---> queue_1 ---> A ------------ B ------------ <---

0熱度

1回答

Kafka deep healthcheck

我們最近遇到了一個問題，卡夫卡經紀人遇到了阻止IO的內核問題（但是我能夠心跳回到zookeeper）。這樣做的結果是卡夫卡經紀人留在ISR集，但實際上無法完成任何任務。的問題是： 1）是否有什麼卡夫卡檢查它發出心跳之前，還是僅僅是弱智化發射心跳（我看https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Pro

0熱度

2回答

的RabbitMQ拒絕連接當我設置默認端口

我實現它在Java和希望有終點的構造函數： public EndPoint(final String endPointName, final String host, final int port){ this.name=endPointName; ConnectionFactory factory = new ConnectionFactory(); factor

1熱度

2回答

使用JMS中的CCDT文件連接到IBM MQ

我試圖使用JMS和客戶端通道定義表（CCDT）連接到IBM MQ。當我單獨指定MQ屬性時，我能夠成功連接到QueueManager。但是，當我嘗試使用CCDT文件時，我得到了下面的異常。由於客戶端通道定義表（CCDT）用於確定客戶端應用程序用於連接到隊列管理器的通道定義，因此我沒有設置QueueManager Name。 ERROR> com.ssc.ach.mq.JMSMQReceiver[

0熱度

1回答

MDB部署成功：然後不會寫入System.out。爲什麼？

我有一個運行WF-8 w/HornetMQ的Java EE項目： --- Sever端部署爲.ear包。 ---客戶端是通過JMS消息傳遞與服務器通信的Java GUI。這一切都工作時收起來。我試圖使用WF-10 w/ArtemisMQ來複活它，它會殺死我。清除所有處理大黃蜂例外後 - >阿蒂米斯，這裏的地方我： --- WF控制檯確認gotest.ear沒有例外部署。（控制檯輸出啓動粘貼

1熱度

1回答

爲CQRS實現打包Masstransit是否是一個好習慣？

我寧願有一個單獨的CommandBus和EventBus也ICommandHandler<TCommand>和IEventHandler<TCommand>使得OrderEventHandler類的樣子： public class OrderEventHandler : IEventHandler<OrderPlaced>, IEventHandler<OrderRegistr

0熱度

1回答

如何在RabbitMQ中的數據庫之間發佈數據更改？

假設我們有兩個應用程序A和B與他們自己的不同數據庫A1（MySQL）和B1（Postgres）相對應。我們在應用A中創建彼此關聯的實體X和Y。 Y屬於X。在每次向數據庫A1（提交後）插入時，我們發佈消息給RabbitMQ以使應用B知道全新的實體。每個實體一個事件 - X1和Y1。一切都很好，如果RabbitMQ保留消息的順序，那麼應用程序B中的工作人員可以首先處理X1，然後再處理Y1，以建立數據庫