BusExtensions

public static class BusExtensions

public static void CancelFuturePublish(this IBus bus, string cancellationKey)

Unschedule all messages matching the cancellationKey.

public static Task CancelFuturePublishAsync(this IBus bus, string cancellationKey)

Unschedule all messages matching the cancellationKey.

public static void FuturePublish<T>(this IBus bus, DateTime futurePublishDate, T message)

Schedule a message to be published at some time in the future. This required the EasyNetQ.Scheduler service to be running.

public static void FuturePublish<T>(this IBus bus, DateTime futurePublishDate, string cancellationKey, T message)

Schedule a message to be published at some time in the future. This required the EasyNetQ.Scheduler service to be running.

public static void FuturePublish<T>(this IBus bus, TimeSpan messageDelay, T message)

Schedule a message to be published at some time in the future, using bare RabbitMQ's capabilites (message time-to-live and dead letter exchange).

public static Task FuturePublishAsync<T>(this IBus bus, DateTime futurePublishDate, T message)

Schedule a message to be published at some time in the future. This required the EasyNetQ.Scheduler service to be running.

public static Task FuturePublishAsync<T>(this IBus bus, DateTime futurePublishDate, string cancellationKey, T message)

Schedule a message to be published at some time in the future. This required the EasyNetQ.Scheduler service to be running.

public static Task FuturePublishAsync<T>(this IBus bus, TimeSpan messageDelay, T message)

Schedule a message to be published at some time in the future, using bare RabbitMQ's capabilites (message time-to-live and dead letter exchange).

EasyNetQ by Mike Hadlow, Contributors (see GitHub repo)