Stack Overflow
Stack Overflow

Questions tagged [rebus-rabbitmq]

25 questions
3
votes
1 answer

How to immediately stop processing new messages when inside a message handler?

I have a Rebus bus setup with a single worker and max parallelism of 1 that processes messages "sequentialy". In case an handler fails, or for specific business reason, I'd like the bus instance to immediately stop processing messages. I tried…
Bredstik
  • 626
  • 5
  • 13
3
votes
1 answer

Notifying all consumers of a message

We are using Rebus 4.2.1 and RabbitMQ What we want to achieve is to have handlers on three (or more) instances all react to the same message. As far as I understood (which may be wrong) - .Publish on the IBus interface should do exactly that (and we…
Goblin
  • 7,970
  • 3
  • 36
  • 40
2
votes
0 answers

Rebus with publish/subscribe in two services - how to properly configure rebus

I am having trouble figuring out the proper way to configure rebus when I have two services that are each publishing and subscribing to events from each other. Let's call the services service1 and service2. Service1 publishes event:…
Eric
  • 1,945
  • 3
  • 23
  • 33
2
votes
0 answers

Rebus saga consistency

I'm facing a weird situation were my sagas sometimes just stop invoking next steps while no errors are written to the logs. so for example consider this (pseudo)code: public async Task Handle(Step1 step1) { //... do something await _bus.Send(new…
Oleg Golovkov
  • 303
  • 2
  • 7
2
votes
1 answer

Rebus - Rabbitmq map all the objects in specified namespace/assembly

In my application I'm configuring Producer with Rabbitmq. my configuration looks like below using (var adapter = new BuiltinHandlerActivator()) { Configure.With(adapter) .Logging(l => l.ColoredConsole(LogLevel.Warn)) …
maniac
  • 159
  • 2
  • 10
2
votes
2 answers

Rebus RabbitMQ IHandleMessage Not working

I have a .NET Core service publishing events to Rebus with RMQ Transport with the following configuration: services.AddRebus(configure => configure .Logging(x => x.Serilog()) .Transport(x =>…
user1957687
  • 89
  • 1
  • 11
2
votes
1 answer

Rebus deferred messages are not being forwarded

I'm using RabbitMq as one-way transport for a topic exchange I configure timeouts to use external manager called "timeout.queue" in RabbitMq (which I had to create manually): configurer.UseExternalTimeoutManager("timeout.queue") This is how a send…
Edson Flores Palma
  • 107
  • 1
  • 10
2
votes
1 answer

Event Published from within a Command Handler

Simple set up of Rebus with Rabbitmq. From within the Command handler in Consumer Window service I am Publishing an event ( at very beginning of the command handler and then I am doing the actual processing). Eventhandler for the event is also…
Karan
  • 65
  • 5
1
vote
1 answer

Can't receive rebus rabbitMQ messages when the object which is published is not shared

When trying to solve my issue with not receiving messages through RabbitMQ using Rebus, I tried playing with this sample: https://github.com/rebus-org/RebusSamples/tree/master/PubSubNative and found that the object, which is published from the…
Michael Winther
  • 471
  • 7
  • 24
1
vote
1 answer

Identify rebus workers

I'm using rebus 6.6.4.0, Rebus.RabbitMq 7.3.5.0 I'm trying to identify each thread in messagehandler by their names. I thought that they are always named by default as Rebus 1 worker 1, but in practice I see that many threads doesn't have names and…
AzizD
  • 103
  • 10
1
vote
1 answer

Rebus CircuitBreaker vs Second Level Retry

How do I decide on whether to use Rebus.CircuitBreaker or Second Level Retry? I feel like that Second Level Retry Can do the work of CircuitBreaker for example if I find the type of error that is is caused by network I can make the message to return…
Amour Rashid
  • 290
  • 3
  • 11
1
vote
1 answer

Rebus Timeout Manager

I would like to ask about Rebus Timeout Manager. I know we have Internal timeout manager and External timeout manager and I have been using Internal timeout manager for quite some time. And I have been sharing one timeout database (Sql Server) for…
Amour Rashid
  • 290
  • 3
  • 11
1
vote
1 answer

Can Rebus be configured to set error queue type to quorum in RabbitMQ?

We have a three node RabbitMq cluster and we are using Rebus to produce and consume messages from Rabbit. The messages that we handle are critical in terms of data safety so we use quorum queues in RabbitMq. The problem right now is that we have a…
codedoings
  • 15
  • 3
1
vote
1 answer

Rebus retry policy when RabbitMQ is temporarily down

I have a dockerized microservice architecture where I am using Rebus with RabbitMQ as message bus. One container is running RabbitMQ. Other containers are running services that communicate with each other via Rebus/RabbitMQ. I want my solution to be…
Bo Christian Skjøtt
  • 733
  • 7
  • 13
1
vote
1 answer

In my Rebus handler I am performing a database operation and then send commands to other three handlers

I want to execute database operation in a handler and then send three commands to other handlers. I want to make sure that all the execution of database operation together with sending commands occur in a transaction and whether all succeed or all…
Amour Rashid
  • 290
  • 3
  • 11
1
2