SendReceiveExtensions
Various extensions for ISendReceive
public static IDisposable Receive<T>(this ISendReceive sendReceive, string queue, Action<T> onMessage, CancellationToken cancellationToken = default)
Receive a message from the specified queue
public static IDisposable Receive<T>(this ISendReceive sendReceive, string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure, CancellationToken cancellationToken = default)
Receive a message from the specified queue
public static IDisposable Receive<T>(this ISendReceive sendReceive, string queue, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
Receive a message from the specified queue
public static IDisposable Receive<T>(this ISendReceive sendReceive, string queue, Func<T, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure, CancellationToken cancellationToken = default)
Receive a message from the specified queue
public static IDisposable Receive(this ISendReceive sendReceive, string queue, Action<IReceiveRegistration> addHandlers, CancellationToken cancellationToken = default)
Receive a message from the specified queue. Dispatch them to the given handlers
public static IDisposable Receive(this ISendReceive sendReceive, string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure, CancellationToken cancellationToken = default)
Receive a message from the specified queue. Dispatch them to the given handlers
public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Action<T> onMessage, CancellationToken cancellationToken = default)
Receive a message from the specified queue
public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure, CancellationToken cancellationToken = default)
Receive a message from the specified queue
public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
Receive a message from the specified queue
public static AwaitableDisposable<IDisposable> ReceiveAsync(this ISendReceive sendReceive, string queue, Action<IReceiveRegistration> addHandlers, CancellationToken cancellationToken = default)
Receive a message from the specified queue. Dispatch them to the given handlers
public static void Send<T>(this ISendReceive sendReceive, string queue, T message, CancellationToken cancellationToken = default)
Send a message directly to a queue