Questions tagged [rebus]

Rebus is a lean service bus implementation for .NET, similar in nature to NServiceBus, MassTransit, only leaner.

Rebus is a lean service bus implementation for .NET, similar in nature to NServiceBus, MassTransit, etc.

Rebus is licensed under MIT, and the source code is available on GitHub, which is also the home of the official documentation wiki.

392 questions
10
votes
2 answers

SqlConnection and avoiding promotion to MSDTC

When we need to do database access in our application, we use the following patterns: For querying, we have a static factory class with a method CreateOpenConnection which does nothing more than new SqlConnection(myConnectionString) and calls…
JulianR
  • 16,213
  • 5
  • 55
  • 85
7
votes
0 answers

How does Rebus work with Azure Service Bus topics?

I'm new to Rebus and Azure Service Bus and would like to understand how Rebus works with Azure Service Bus topics and queues. I've managed to successfully get Rebus to work with ASB but am a bit puzzled as to what's going on under the covers. I have…
Craig Shearer
  • 14,222
  • 19
  • 64
  • 95
6
votes
1 answer

How should I set rebus up for one producer and many consumers

I am going through the samples and reading the docs but I am still not sure of how to configure rebus for my scenario (or that using the bus is a good fit). I have one producer of Tasks to do, lets say ImportOrder and CalculateOrderPrice I want to…
Jon
  • 561
  • 4
  • 14
5
votes
1 answer

Context is lost when reassigning Transaction.Current in async/await code

When reassigning Transaction.Current, I seem to lose the original TransactionScopeAsyncFlowOption behavior of my TransactionScope. The code after the second await loses it's Transaction.Current value. Sample code (Linqpad): async Task Main() { …
ThomasDC
  • 484
  • 3
  • 11
5
votes
1 answer

DbContext creation into message handler

I have a dll wich expose a type like public class MyDbContext { [...] } inside this library I also have an IPackage implementation which register the MyDbContext in the container like public void RegisterServices( Container container ) { …
Lorenzo
  • 29,081
  • 49
  • 125
  • 222
5
votes
1 answer

Rebus crash in .NET async core

I am trying to upgrade an existing website from Rebus 0.45 to Rebus 2.0 and have run into a problem where System.Web.ThreadContext.AssociateWithCurrentThread crashes with a null reference. I have absolutely no idea about why, so I am looking for…
Jørn Wildt
  • 4,274
  • 1
  • 21
  • 31
5
votes
1 answer

How can we avoid multiple Rebus messages when its has been timed out?

We are using Rebus as a queue system with Sql server. We have several recipients for different types of messages. Each message can be handled by several workers of a certain type. One message should only be handled/processed by one worker (the first…
jopa
  • 145
  • 1
  • 9
4
votes
2 answers

Rebus Circuit Breaker Implementation?

I have been working quite a bit with Rebus lately and so far it has been great. One area of concern is when we have thousands or hundreds of thousands of messages that are being processed and a dependent service, like the database or RabbitMQ, is…
Rob Packwood
  • 3,698
  • 4
  • 32
  • 48
4
votes
2 answers

Configuring Rebus in a .net core Worker Service (or a Console App)

I have seen that Adding rebus in the ASP.NET Core execution pipeline is very neat using Startup.cs. I wonder if there is a same neat way to do the same for Worker service or generally a console app. Most .net core console apps I have seen are very…
Amour Rashid
  • 290
  • 3
  • 11
4
votes
1 answer

Rebus with Azure Service Bus, Competing consumers and multi-tenancy

I have been trying to setup Rebus for Azure Service Bus, but I find it hard to find examples that fit my use case, or to construct a solution by myself. I have multiple instances producing Message1, each instance runs for a specific client, however…
Rich_Rich
  • 427
  • 3
  • 15
4
votes
1 answer

Moving Error message from error queue back to original queue with Rebus

Is it possible to move error message from error queue to its original queue, programmatically or via UI? Update Questions below on the code below: 1 Does the code below apply to Publiser or Subscriber or both? The code below: …
Pingpong
  • 7,681
  • 21
  • 83
  • 209
4
votes
1 answer

Random Messages Not Being Handled in Rebus

I have an odd issue with my implementation of Rebus which has been working for the past couple of years without any issue, and I am trying to figure out the scope of the problem and where to focus my troubleshooting effort. A little context: We…
Tom Miller
  • 536
  • 1
  • 4
  • 14
4
votes
1 answer

Rebus Sagas, Revisions and DeferredMessages

I'm trying to configure a Saga that works in the following way: Saga receives a Shipping Order Message. That shipping order has a RouteId property that I can use to correlate Shipping Orders for the same "truck" These shipping orders are created by…
Gerson Dias
  • 77
  • 2
  • 7
4
votes
1 answer

Examining rebus handlers in progress and stopping rebus from accepting new messages

I have a web app that uses Rebus with Azure Service Bus queues as a transport. It is configured with Simple Injector container. During app disposal I want to stop rebus from accepting new messages and examine number of messages being handled at the…
Gregi
  • 155
  • 1
  • 6
4
votes
1 answer

How to forward a message with exceptions to Rebus error queue

Using second-level retries in Rebus (https://github.com/rebus-org/Rebus/wiki/Automatic-retries-and-error-handling) I need to forward a message to an error queue after n retries. This…
Christian Dalager
  • 6,603
  • 4
  • 21
  • 27
1
2 3
26 27