easynetq

0热度

1回答

我有一位工作人员订阅rabbitmq上的预先存在的队列。出于冗余目的，我们决定添加另一个连接到同一队列的工作人员。是否有可能建立第一个工作人员获取排队专用连接的设置，以便第二个工作人员不能将邮件出列并因此充当备用工人？

1热度

1回答

我们计划将RabbitMq用于我们的消息服务，我们将把所有消息请求发布到RabbitMq持久队列中。对于.Net客户端，我们决定使用EasyNetQ，所以问题是如果RabbitMq服务器在发布消息时发生故障，应如何处理？ - 我们应该发现异常并将消息保存到数据库并重新发布预定作业吗？ - 我们应该使用断路器吗？ - 还有什么？我想听听你的经历。

0热度

1回答

与rabbitmq.client版本的噩梦

使用easynetq时，我遇到了rabbitmq.client版本的问题，但我不知道究竟是什么原因造成的！我的解决方案包含一个WindowsService（exe文件）和多个库项目，都是针对.NET 4.6.2构建的。在我exe.conf（服务可执行的）文件，我看到下面的条目： <runtime> <assemblyBinding xmlns="urn:schemas-microsoft-co

2热度

1回答

在EasyNetQ中声明具有特定名称的请求/响应模式的响应队列

在EasyNetQ中使用请求/响应消息传递模式时，我需要在请求队列上发送消息之前声明一个专用响应队列（使用特定名称）？我认为框架在后台声明响应队列，但我怎样才能给这个响应队列一个特定的名字？我没有看到文档中这方面的消息，在https://github.com/EasyNetQ/EasyNetQ/wiki/Request-Response

0热度

1回答

EasyNetQ消息发布程序模式

我正在为EasyNetQ发布封装以将消息发布到RabbitMQ。有大量需要发布的消息。我是否应该使用模式来使用IBus发布消息，还是应该将IBus类型var声明为类级别static var，并在应用程序结束时进行处理？ using (IBus bus = RabbitHutch.CreateBus(rabbitMQConnectionString)) { bus.publish("ss");

0热度

2回答

死亡字体更改类型时，如何反序列化一封死信字母？

我想写一个死信处理程序服务，从死信队列中读取消息，然后根据类型，内容等进行消息处理。在我的C＃应用程序中，我是使用EasyNetQ。我有一个名为MyMessage的基本消息类型，然后是一些子类型。 EasyNetQ没有序列化消息的问题，将它们发送到交换机，将它们从队列中拉出，然后将消息反序列化为原始类型。但是，如果我将我的死信处理程序中的AdvancedBus设置为使用MyMessage类

0热度

1回答

如何从EasyNetQ中的消息中获取RabbitMQ死信头信息？

这是一个后续到以前的问题，我问： How do I deserialize a dead lettered message when dead lettering changes the type? 我现在遇到的问题是，我不能看到额外的头信息是RabbitMQ的增加，当一个消息是一纸空文。额外的头信息在“x-death”之下，它们是计数，原因，队列，时间，交换和路由密钥。一旦EasyNetQ将消

0热度

1回答

包含来自消费者的ACK的较小任务的任务

我正在处理一些POC project并尝试解决以下问题。我有一个Publisher它发送一个消息队列： bus.PublishAsync<IBaseScenario>(new TestScenario()) .ContinueWith(task => { if (task.IsCompleted && !task.IsFaulted)

0热度

1回答

RabbitMQ - 当订阅服务失败并出现一些错误时如何停止发布服务

我在C＃中有2个窗口服务。服务1将消息发布到RabbitMQ队列。服务2订阅RabbitMQ队列。服务2还连接到TCP服务器，并将它从RabbitMQ收到的消息发送到此服务器。我的问题是，是否有任何方法来阻止服务1发布消息到队列中，当服务2使用此消息由于某些错误而失败（大多数是SocketException，如果它无法连接到服务器）。任何指针都会非常有帮助。如果需要更多信息，请让我知道

0热度

1回答

Spring Ampq类型名称和EasyNetQ

我需要发送消息在C#微型服务与EasyNetQ和Java与Spring Amqp。问题是属性消息，类型从Spring Boot Amqp在属性__type__标题容器中，而在EasynetQ中预期来自名为type的其他属性。任何人都可以告诉我我需要自定义以让它们交流吗？ Spring Amqp : "Headers":{"__TypeId__":"com.fastdeliveryse