Questions tagged [rebus-azureservicebus]

31 questions
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
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
1 answer

Is it possible to use Rebus with Azure Functions?

I am new to Rebus and was looking for some documentation about triggering azure functions using Rebus with Azure Service Bus provider. Is it possible?
Leonardo Lurci
  • 2,409
  • 3
  • 18
  • 34
2
votes
1 answer

Lifecycle of BuiltinHandlerActivator and application requests with Rebus

I have questions regarding lifecycles of various Rebus’s object related to application requests for Publisher and Subscriber: Please see below: Publisher 1 Must the code below be initialised once and only once for the lifetime of the app? For…
Pingpong
  • 7,681
  • 21
  • 83
  • 209
1
vote
1 answer

Rebus with secondLevelRetriesEnabled enable retries doesn't stop retrying on IFailed handler

I'm having an issue with rebus (that I'm sure it's me the problem) and here's the issue: I have second level retries enabled. In the normal handler I throw a FailFastException In the IFailed handler I got the message and I do a kind of "delayed"…
Coastpear
  • 374
  • 2
  • 15
1
vote
0 answers

Rebus Azure Pub Sub pattern

I'm exploring the Rebus library. I implemented the Pub/Sub successfully in Microsoft.NET.Sdk.Worker project with FileSystem transport. But I'm struggling to make it work with AzureServiceBus. I have below configuration in Program.cs: IHost host =…
harry777
  • 61
  • 1
  • 5
1
vote
1 answer

Rebus: Unable to modify / add new headers with BeforeMessageHandled event

We are using the Rebus framework in our application and we currently have some issues adding additional headers before the messages are handled by our handlers. In my startup: }).Events(e => { e.BeforeMessageSent +=…
Enrico
  • 2,734
  • 1
  • 27
  • 40
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

Request-reply with more clients and one server

How does Rebus ensure that a requester gets the response destined for the requester from the server? The context is a setup with multiple clients, one backend server and two azure servicebus queues one for the client side and one for the server…
Jan Rou
  • 151
  • 2
  • 10
1
vote
1 answer

Why is Rebus.Send not working after update to .NET 5 using Azure Service Bus

We have a .net core 3.1 web project running with Rebus and Azure Service Bus. After updating to .NET 5 we can no longer send messages to the Azure Service Bus queue using Rebus. No code changes have been made, only update to .NET 5 and latest…
user5283666
1
vote
1 answer

Handling defunct deferred (timeout) messages?

I am new to Rebus and am trying to get up to speed with some patterns we currently use in Azure Logic Apps. The current target implementation would use Azure Service Bus with Saga storage preferably in Cosmos DB (still investigating that sample…
G Mac
  • 160
  • 1
  • 9
1
vote
1 answer

Rebus with Azure Service Bus, subscribe to an interface

I'd like to receive all the messages that are implementing a specific interface: public interface IBusItem { Guid BusItemId { get; } DateTime Timestamp { get; } } For example, I have a message like this: public class SomeMessage :…
Alberto
  • 199
  • 2
  • 17
1
vote
1 answer

How to use Rebus data bus attachments with Rebus.Async replies

I'm using Rebus.Async to send a request. Upon receipt, the consumer replies with a large amount of data, which it uploads to Azure Blob Storage using Rebus.AzureBlobs. The sender receives the reply and attempts to read the attachment. When this…
Eric Eskildsen
  • 4,269
  • 2
  • 38
  • 55
1
vote
1 answer

Rebus - System.MissingMethodException : Method not found: 'System.Threading.Tasks.Task Rebus.Bus.IBus.Send'

When calling SendRequest using Rebus.Async, I get this error: System.MissingMethodException : Method not found: 'System.Threading.Tasks.Task Rebus.Bus.IBus.Send(System.Object, System.Collections.Generic.Dictionary`2)'. How can I resolve this?
Eric Eskildsen
  • 4,269
  • 2
  • 38
  • 55
1
vote
1 answer

Rebus Pub Sub: Retrieve headers on subscriber

Headers are published with Azure Service Bus, like below: string content = "body"; await _busPublisher.Activator.Bus.Publish(content, headers); How to retrieve both header and content on subscriber? class Handler : IHandleMessages
Pingpong
  • 7,681
  • 21
  • 83
  • 209
1
2 3