Class SendExecuteExtensions

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public static class SendExecuteExtensions

Inheritance

object

SendExecuteExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

Send(ISendEndpoint, object, Action<SendContext>, CancellationToken)

Send a message, using a callback to modify the send context instead of building a pipe from scratch

public static Task Send(this ISendEndpoint endpoint, object message, Action<SendContext> callback, CancellationToken cancellationToken = default)

Parameters

endpoint ISendEndpoint

The endpoint to send the message

message object

The message

callback Action<SendContext>

The callback for the send context

cancellationToken CancellationToken

To cancel the send from happening

Returns

Task

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

Send(ISendEndpoint, object, Func<SendContext, Task>, CancellationToken)

Send a message, using a callback to modify the send context instead of building a pipe from scratch

public static Task Send(this ISendEndpoint endpoint, object message, Func<SendContext, Task> callback, CancellationToken cancellationToken = default)

Parameters

endpoint ISendEndpoint

The endpoint to send the message

message object

The message

callback Func<SendContext, Task>

The callback for the send context

cancellationToken CancellationToken

To cancel the send from happening

Returns

Task

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

Send(ISendEndpoint, object, Type, Action<SendContext>, CancellationToken)

Send a message, using a callback to modify the send context instead of building a pipe from scratch

public static Task Send(this ISendEndpoint endpoint, object message, Type messageType, Action<SendContext> callback, CancellationToken cancellationToken = default)

Parameters

endpoint ISendEndpoint

The endpoint 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

cancellationToken CancellationToken

To cancel the send from happening

Returns

Task

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

Send(ISendEndpoint, object, Type, Func<SendContext, Task>, CancellationToken)

Send a message, using a callback to modify the send context instead of building a pipe from scratch

public static Task Send(this ISendEndpoint endpoint, object message, Type messageType, Func<SendContext, Task> callback, CancellationToken cancellationToken = default)

Parameters

endpoint ISendEndpoint

The endpoint 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

cancellationToken CancellationToken

To cancel the send from happening

Returns

Task

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

Send<T>(ISendEndpoint, object, Action<SendContext<T>>, CancellationToken)

Send a message, using a callback to modify the send context instead of building a pipe from scratch

public static Task Send<T>(this ISendEndpoint endpoint, object values, Action<SendContext<T>> callback, CancellationToken cancellationToken = default) where T : class

Parameters

endpoint ISendEndpoint

The endpoint to send the message

values object

The values that map to the object

callback Action<SendContext<T>>

The callback for the send context

cancellationToken CancellationToken

To cancel the send from happening

Returns

Task

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

Type Parameters

T

The message type

Send<T>(ISendEndpoint, object, Func<SendContext<T>, Task>, CancellationToken)

Send a message, using a callback to modify the send context instead of building a pipe from scratch

public static Task Send<T>(this ISendEndpoint endpoint, object values, Func<SendContext<T>, Task> callback, CancellationToken cancellationToken = default) where T : class

Parameters

endpoint ISendEndpoint

The endpoint to send the message

values object

The values that map to the object

callback Func<SendContext<T>, Task>

The callback for the send context

cancellationToken CancellationToken

To cancel the send from happening

Returns

Task

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

Type Parameters

T

The message type

Send<T>(ISendEndpoint, T, Action<SendContext<T>>, CancellationToken)

Send a message, using a callback to modify the send context instead of building a pipe from scratch

public static Task Send<T>(this ISendEndpoint endpoint, T message, Action<SendContext<T>> callback, CancellationToken cancellationToken = default) where T : class

Parameters

endpoint ISendEndpoint

The endpoint to send the message

message T

The message

callback Action<SendContext<T>>

The callback for the send context

cancellationToken CancellationToken

To cancel the send from happening

Returns

Task

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

Type Parameters

T

The message type

Send<T>(ISendEndpoint, T, Func<SendContext<T>, Task>, CancellationToken)

Send a message, using a callback to modify the send context instead of building a pipe from scratch

public static Task Send<T>(this ISendEndpoint endpoint, T message, Func<SendContext<T>, Task> callback, CancellationToken cancellationToken = default) where T : class

Parameters

endpoint ISendEndpoint

The endpoint to send the message

message T

The message

callback Func<SendContext<T>, Task>

The callback for the send context

cancellationToken CancellationToken

To cancel the send from happening

Returns

Task

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

Type Parameters

T

The message type

ToPipe(Action<SendContext>)

public static IPipe<SendContext> ToPipe(this Action<SendContext> callback)

Parameters

callback Action<SendContext>

Returns

IPipe<SendContext>

ToPipe(Func<SendContext, Task>)

public static IPipe<SendContext> ToPipe(this Func<SendContext, Task> callback)

Parameters

callback Func<SendContext, Task>

Returns

IPipe<SendContext>

ToPipe<T>(Action<SendContext<T>>)

public static IPipe<SendContext<T>> ToPipe<T>(this Action<SendContext<T>> callback) where T : class

Parameters

callback Action<SendContext<T>>

Returns

IPipe<SendContext<T>>

Type Parameters

T

ToPipe<T>(Func<SendContext<T>, Task>)

public static IPipe<SendContext<T>> ToPipe<T>(this Func<SendContext<T>, Task> callback) where T : class

Parameters

callback Func<SendContext<T>, Task>

Returns

IPipe<SendContext<T>>

Type Parameters

T