Class RespondAsyncExecuteExtensions

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public static class RespondAsyncExecuteExtensions

Inheritance

object

RespondAsyncExecuteExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

RespondAsync(ConsumeContext, object, Action<SendContext>)

public static Task RespondAsync(this ConsumeContext context, object message, Action<SendContext> callback)

Parameters

context ConsumeContext

message object

callback Action<SendContext>

Returns

Task

The task which is completed once the Send is acknowledged by the broker

RespondAsync(ConsumeContext, object, Func<SendContext, Task>)

Responds to the current message immediately, returning the Task for the sending message. The caller may choose to await the response to ensure it was sent, or allow the framework to wait for it (which will happen automatically before the message is acked)

public static Task RespondAsync(this ConsumeContext context, object message, Func<SendContext, Task> callback)

Parameters

context ConsumeContext

The context to send the message

message object

The message

callback Func<SendContext, Task>

The callback for the send context

Returns

Task

The task which is completed once the Send is acknowledged by the broker

RespondAsync(ConsumeContext, object, Type, Action<SendContext>)

Responds to the current message immediately, returning the Task for the sending message. The caller may choose to await the response to ensure it was sent, or allow the framework to wait for it (which will happen automatically before the message is acked)

public static Task RespondAsync(this ConsumeContext context, object message, Type messageType, Action<SendContext> callback)

Parameters

context ConsumeContext

The context to send the message

message object

The message

messageType Type

The message type to send the object as

callback Action<SendContext>

The callback for the send context

Returns

Task

The task which is completed once the Send is acknowledged by the broker

RespondAsync(ConsumeContext, object, Type, Func<SendContext, Task>)

Responds to the current message immediately, returning the Task for the sending message. The caller may choose to await the response to ensure it was sent, or allow the framework to wait for it (which will happen automatically before the message is acked)

public static Task RespondAsync(this ConsumeContext context, object message, Type messageType, Func<SendContext, Task> callback)

Parameters

context ConsumeContext

The context to send the message

message object

The message

messageType Type

The message type to send the object as

callback Func<SendContext, Task>

The callback for the send context

Returns

Task

The task which is completed once the Send is acknowledged by the broker

RespondAsync<T>(ConsumeContext, object, Action<SendContext<T>>)

Responds to the current message immediately, returning the Task for the sending message. The caller may choose to await the response to ensure it was sent, or allow the framework to wait for it (which will happen automatically before the message is acked)

public static Task RespondAsync<T>(this ConsumeContext context, object values, Action<SendContext<T>> callback) where T : class

Parameters

context ConsumeContext

The context to send the message

values object

The values that map to the object

callback Action<SendContext<T>>

The callback for the send context

Returns

Task

The task which is completed once the Send is acknowledged by the broker

Type Parameters

T

The message type

RespondAsync<T>(ConsumeContext, object, Func<SendContext<T>, Task>)

Responds to the current message immediately, returning the Task for the sending message. The caller may choose to await the response to ensure it was sent, or allow the framework to wait for it (which will happen automatically before the message is acked)

public static Task RespondAsync<T>(this ConsumeContext context, object values, Func<SendContext<T>, Task> callback) where T : class

Parameters

context ConsumeContext

The context to send the message

values object

The values that map to the object

callback Func<SendContext<T>, Task>

The callback for the send context

Returns

Task

The task which is completed once the Send is acknowledged by the broker

Type Parameters

T

The message type

RespondAsync<T>(ConsumeContext, T, Action<SendContext<T>>)

Responds to the current message immediately, returning the Task for the sending message. The caller may choose to await the response to ensure it was sent, or allow the framework to wait for it (which will happen automatically before the message is acked)

public static Task RespondAsync<T>(this ConsumeContext context, T message, Action<SendContext<T>> callback) where T : class

Parameters

context ConsumeContext

The context to send the message

message T

The message

callback Action<SendContext<T>>

The callback for the send context

Returns

Task

The task which is completed once the Send is acknowledged by the broker

Type Parameters

T

The message type

RespondAsync<T>(ConsumeContext, T, Func<SendContext<T>, Task>)

Responds to the current message immediately, returning the Task for the sending message. The caller may choose to await the response to ensure it was sent, or allow the framework to wait for it (which will happen automatically before the message is acked)

public static Task RespondAsync<T>(this ConsumeContext context, T message, Func<SendContext<T>, Task> callback) where T : class

Parameters

context ConsumeContext

The context to send the message

message T

The message

callback Func<SendContext<T>, Task>

The callback for the send context

Returns

Task

The task which is completed once the Send is acknowledged by the broker

Type Parameters

T

The message type