masstransit

0熱度

1回答

我有出版商： static void Main() { var bus = ServiceBusFactory.New(sbc => { sbc.UseRabbitMq(r => r.ConfigureHost(new MessageUrn("rabbitmq://localhost/test123"), c => { })); sbc

0熱度

1回答

Masstransit + RabbitMQ。在兩種不同的消息類型之間共享一個隊列

我有一個發佈者，它將消息發佈到rabbitmq：// localhost/test123隊列。一條消息具有TestMessage類型，另一條是TestMessage2類型。出版商配置： sbc.UseRabbitMq(r => r.ConfigureHost(new MessageUrn("rabbitmq://localhost/test123"), c => { })); sbc.UseL

0熱度

2回答

如何我可以讀取Masstransit中間件/ Filter類

發送的消息我有一個像下面 public class TestFilter<T> : IFilter<T> where T : class, PipeContext { public void Probe(ProbeContext context){} public async Task Send(T context, IPipe<T> next) {

0熱度

1回答

發佈於CreateUsingInMemory總線崩潰應用程序

以下代碼僅會使應用程序崩潰，在調用發佈時，不會發生錯誤並且應用程序會關閉。我真正想做的是執行unittests，這段代碼只是爲了提供一個乾淨的例子的摘要。當我將相應的代碼作爲unittest運行時，我收到一條錯誤消息，指出線程正在中止。代碼使用的是MassTransit nuget包的3.5.6版本。任何人都可以看到我做錯了什麼？ using System; using System.Thr

0熱度

1回答

UseInMemoryOutbox在Masstransit狀態機，保留髮布消息

我有配置了UseInMemoryOutbox（一MT狀態機），這樣是事件處理的一部分將只發布的任何消息的訂單後在管道中的最後一步是成功的完成，在我的情況是，狀態持久性Couchbase。 Initially(When(A). ThenAsync(async context => { context.Instance.IsAutoApprov

2熱度

1回答

Masstransit狀態機 - 重試機制

如果消息由於異常而被「重試」，是否將其物理返回到隊列？到一開始？到最後？它是否在隊列中存在的消息之後被重新處理？它是否保存在應用程序內存中？我還沒有發現masstransit重試機制流在文檔中的任何說明。請參閱任何解釋它的文檔，謝謝。

0熱度

1回答

如何使用masstransit與messgedata註冊類乾淨

我使用MassTransit，以便在整個Azure的服務總線的消息路由我試圖使用MessageData（Azure的斑點）我有一個創建了一個「核心」庫總線，其中有代碼來設置端點。我有一個叫messages庫，定義了讓過去（由發送者和消費者使用）消息我有一個「消費者」誰需要得到的消息。我見過的人告訴我，我只需添加這樣的事情： cfg.ReceiveEndpoint("my_queue",

0熱度

1回答

使用MassTransit請求/響應對話擴展訂戶

我有一個使用Masstransit/RabbitMq在Web項目中使用的企業服務總線。我使用Masstransit的Request/Response模式來完成RPC over MQ。我在處理不同類型消息的總線中創建多個ReceiveEndpoint。 ESB使用自定義配置文件來創建多個總線，所以我可以以某種方式在邏輯上實現Qos，甚至在單獨的服務器上通過網絡分發消費者以增加或多或少的性能。最近

0熱度

1回答

如何隱藏MassTransit的接口/ RabbitMQ

我正在RabbitMQ中使用MassTransit。它工作得很好。但是，我注意到在RabbitMQ中，對於發佈的消息正在實現的每個接口，都會創建交換。這不是必需的，只是使RabbitMQ交易所混亂。所以，我的問題是：如何避免爲這些接口創建交換？有沒有可以照顧這個的一些屬性？

0熱度

1回答

如何使用作用域終身

我們可以設置Consume Observer使用以下方式創建MassTransit消息攔截器（觀察員） busControl.ConnectConsumeObserver(container.GetInstance<MessageConsumerInterceptor>()); 我想範圍生活方式適用於MessageConsumerInterceptor，這樣我可以填充/消耗或處理之前初始化一些