我尝试使用MassTransit向Azure中名为events的主题发布消息。我在配置MassTransit以使用预定义的主题events时遇到了问题,相反,它为消息类型创建了一个由名称空间/类名命名的新主题。所以我想知道如何指定使用哪个主题,而不是创建一个新的主题。
下面是我测试过的代码:
using System;
using System.Threading.Tasks;
using MassTransit;
using MassTransit.AzureServiceBusTransport;
using Microsoft.ServiceBus;
namespace Publish
当实际的代理(RabbitMQ)宕机时,我正在为使用Masstransit发布的消息实现故障转移解决方案。我们的想法是捕获失败的消息,将它们存储在某个地方,然后在代理启动并运行时重新发布。 可能的解决方案是通过实现PublishFault方法来使用PublishObserver。 Masstransit的版本是5.5.5 public Task PublishFault<T>(PublishContext<T> context, Exception exception) where T : class
{
var message = conte
我在MassTransit和rabbitMQ中使用c#。
我向使用者发送命令,在使用者中获取它们并执行所需的任务,并尝试向publisher发送响应。
using MyCompany.Messaging;
using System;
using System.Threading.Tasks;
namespace MassTransit.Receiver
{
public class RegisterCustomerConsumer : IConsumer<IRegisterCustomer>
{
public Task Consume
我正在尝试创建过滤器来填充使用者中的correlationId,并在发送的消息中添加这个correlationId。
但是,我相信,由于它是多总线的上下文在2配置的总线之间是不同的,是否有任何方法使这个工作。
下面是其中一个过滤器的示例:
public class CorrelationSendFilter<T> :
IFilter<SendContext<T>>
where T : class
{
private CorrelationContext _correlationContext;
public Correlat