Class BatchProduceExtensions

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public static class BatchProduceExtensions

Inheritance

object

BatchProduceExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

PublishBatch(IPublishEndpoint, IEnumerable<object>, IPipe<PublishContext>, CancellationToken)

Publish a message batch

public static Task PublishBatch(this IPublishEndpoint endpoint, IEnumerable<object> messages, IPipe<PublishContext> pipe, CancellationToken cancellationToken = default)

Parameters

endpoint IPublishEndpoint

The destination endpoint

messages IEnumerable<object>

pipe IPipe<PublishContext>

cancellationToken CancellationToken

Returns

Task

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

PublishBatch(IPublishEndpoint, IEnumerable<object>, Action<PublishContext>, CancellationToken)

Publish a message batch

public static Task PublishBatch(this IPublishEndpoint endpoint, IEnumerable<object> messages, Action<PublishContext> callback, CancellationToken cancellationToken = default)

Parameters

endpoint IPublishEndpoint

The destination endpoint

messages IEnumerable<object>

callback Action<PublishContext>

The callback for the publish context

cancellationToken CancellationToken

Returns

Task

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

PublishBatch(IPublishEndpoint, IEnumerable<object>, Func<PublishContext, Task>, CancellationToken)

Publish a message batch

public static Task PublishBatch(this IPublishEndpoint endpoint, IEnumerable<object> messages, Func<PublishContext, Task> callback, CancellationToken cancellationToken = default)

Parameters

endpoint IPublishEndpoint

The destination endpoint

messages IEnumerable<object>

callback Func<PublishContext, Task>

The callback for the publish context

cancellationToken CancellationToken

Returns

Task

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

PublishBatch(IPublishEndpoint, IEnumerable<object>, CancellationToken)

Publish a message batch

public static Task PublishBatch(this IPublishEndpoint endpoint, IEnumerable<object> messages, CancellationToken cancellationToken = default)

Parameters

endpoint IPublishEndpoint

The destination endpoint

messages IEnumerable<object>

cancellationToken CancellationToken

Returns

Task

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

PublishBatch(IPublishEndpoint, IEnumerable<object>, Type, IPipe<PublishContext>, CancellationToken)

Publish a message batch

public static Task PublishBatch(this IPublishEndpoint endpoint, IEnumerable<object> messages, Type messageType, IPipe<PublishContext> pipe, CancellationToken cancellationToken = default)

Parameters

endpoint IPublishEndpoint

The destination endpoint

messages IEnumerable<object>

messageType Type

pipe IPipe<PublishContext>

cancellationToken CancellationToken

Returns

Task

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

PublishBatch(IPublishEndpoint, IEnumerable<object>, Type, Action<PublishContext>, CancellationToken)

Publish a message batch

public static Task PublishBatch(this IPublishEndpoint endpoint, IEnumerable<object> messages, Type messageType, Action<PublishContext> callback, CancellationToken cancellationToken = default)

Parameters

endpoint IPublishEndpoint

The destination endpoint

messages IEnumerable<object>

messageType Type

callback Action<PublishContext>

The callback for the publish context

cancellationToken CancellationToken

Returns

Task

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

PublishBatch(IPublishEndpoint, IEnumerable<object>, Type, Func<PublishContext, Task>, CancellationToken)

Publish a message batch

public static Task PublishBatch(this IPublishEndpoint endpoint, IEnumerable<object> messages, Type messageType, Func<PublishContext, Task> callback, CancellationToken cancellationToken = default)

Parameters

endpoint IPublishEndpoint

The destination endpoint

messages IEnumerable<object>

messageType Type

callback Func<PublishContext, Task>

The callback for the publish context

cancellationToken CancellationToken

Returns

Task

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

PublishBatch(IPublishEndpoint, IEnumerable<object>, Type, CancellationToken)

Publish a message batch

public static Task PublishBatch(this IPublishEndpoint endpoint, IEnumerable<object> messages, Type messageType, CancellationToken cancellationToken = default)

Parameters

endpoint IPublishEndpoint

The destination endpoint

messages IEnumerable<object>

messageType Type

cancellationToken CancellationToken

Returns

Task

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

PublishBatch<T>(IPublishEndpoint, IEnumerable<T>, IPipe<PublishContext<T>>, CancellationToken)

Publish a message batch

public static Task PublishBatch<T>(this IPublishEndpoint endpoint, IEnumerable<T> messages, IPipe<PublishContext<T>> pipe, CancellationToken cancellationToken = default) where T : class

Parameters

endpoint IPublishEndpoint

The destination endpoint

messages IEnumerable<T>

pipe IPipe<PublishContext<T>>

cancellationToken CancellationToken

Returns

Task

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

Type Parameters

T

The message type

PublishBatch<T>(IPublishEndpoint, IEnumerable<T>, Action<PublishContext<T>>, CancellationToken)

Publish a message batch

public static Task PublishBatch<T>(this IPublishEndpoint endpoint, IEnumerable<T> messages, Action<PublishContext<T>> callback, CancellationToken cancellationToken = default) where T : class

Parameters

endpoint IPublishEndpoint

The destination endpoint

messages IEnumerable<T>

callback Action<PublishContext<T>>

The callback for the publish context

cancellationToken CancellationToken

Returns

Task

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

Type Parameters

T

The message type

PublishBatch<T>(IPublishEndpoint, IEnumerable<T>, Func<PublishContext<T>, Task>, CancellationToken)

Publish a message batch

public static Task PublishBatch<T>(this IPublishEndpoint endpoint, IEnumerable<T> messages, Func<PublishContext<T>, Task> callback, CancellationToken cancellationToken = default) where T : class

Parameters

endpoint IPublishEndpoint

The destination endpoint

messages IEnumerable<T>

callback Func<PublishContext<T>, Task>

The callback for the publish context

cancellationToken CancellationToken

Returns

Task

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

Type Parameters

T

The message type

PublishBatch<T>(IPublishEndpoint, IEnumerable<T>, CancellationToken)

Send a message

public static Task PublishBatch<T>(this IPublishEndpoint endpoint, IEnumerable<T> messages, CancellationToken cancellationToken = default) where T : class

Parameters

endpoint IPublishEndpoint

The destination endpoint

messages IEnumerable<T>

cancellationToken CancellationToken

Returns

Task

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

Type Parameters

T

The message type

SendBatch(ISendEndpoint, IEnumerable<object>, IPipe<SendContext>, CancellationToken)

Send a message batch

public static Task SendBatch(this ISendEndpoint endpoint, IEnumerable<object> messages, IPipe<SendContext> pipe, CancellationToken cancellationToken = default)

Parameters

endpoint ISendEndpoint

The destination endpoint

messages IEnumerable<object>

pipe IPipe<SendContext>

cancellationToken CancellationToken

Returns

Task

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

SendBatch(ISendEndpoint, IEnumerable<object>, Action<SendContext>, CancellationToken)

Send a message batch

public static Task SendBatch(this ISendEndpoint endpoint, IEnumerable<object> messages, Action<SendContext> callback, CancellationToken cancellationToken = default)

Parameters

endpoint ISendEndpoint

The destination endpoint

messages IEnumerable<object>

callback Action<SendContext>

The callback for the send context

cancellationToken CancellationToken

Returns

Task

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

SendBatch(ISendEndpoint, IEnumerable<object>, Func<SendContext, Task>, CancellationToken)

Send a message batch

public static Task SendBatch(this ISendEndpoint endpoint, IEnumerable<object> messages, Func<SendContext, Task> callback, CancellationToken cancellationToken = default)

Parameters

endpoint ISendEndpoint

The destination endpoint

messages IEnumerable<object>

callback Func<SendContext, Task>

The callback for the send context

cancellationToken CancellationToken

Returns

Task

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

SendBatch(ISendEndpoint, IEnumerable<object>, CancellationToken)

Send a message batch

public static Task SendBatch(this ISendEndpoint endpoint, IEnumerable<object> messages, CancellationToken cancellationToken = default)

Parameters

endpoint ISendEndpoint

The destination endpoint

messages IEnumerable<object>

cancellationToken CancellationToken

Returns

Task

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

SendBatch(ISendEndpoint, IEnumerable<object>, Type, IPipe<SendContext>, CancellationToken)

Send a message

public static Task SendBatch(this ISendEndpoint endpoint, IEnumerable<object> messages, Type messageType, IPipe<SendContext> pipe, CancellationToken cancellationToken = default)

Parameters

endpoint ISendEndpoint

The destination endpoint

messages IEnumerable<object>

messageType Type

pipe IPipe<SendContext>

cancellationToken CancellationToken

Returns

Task

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

SendBatch(ISendEndpoint, IEnumerable<object>, Type, Action<SendContext>, CancellationToken)

Send a message

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

Parameters

endpoint ISendEndpoint

The destination endpoint

messages IEnumerable<object>

messageType Type

callback Action<SendContext>

The callback for the send context

cancellationToken CancellationToken

Returns

Task

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

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

Send a message

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

Parameters

endpoint ISendEndpoint

The destination endpoint

messages IEnumerable<object>

messageType Type

callback Func<SendContext, Task>

The callback for the send context

cancellationToken CancellationToken

Returns

Task

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

SendBatch(ISendEndpoint, IEnumerable<object>, Type, CancellationToken)

Send a message

public static Task SendBatch(this ISendEndpoint endpoint, IEnumerable<object> messages, Type messageType, CancellationToken cancellationToken = default)

Parameters

endpoint ISendEndpoint

The destination endpoint

messages IEnumerable<object>

messageType Type

cancellationToken CancellationToken

Returns

Task

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

SendBatch<T>(ISendEndpoint, IEnumerable<T>, IPipe<SendContext<T>>, CancellationToken)

Send a message

public static Task SendBatch<T>(this ISendEndpoint endpoint, IEnumerable<T> messages, IPipe<SendContext<T>> pipe, CancellationToken cancellationToken = default) where T : class

Parameters

endpoint ISendEndpoint

The destination endpoint

messages IEnumerable<T>

pipe IPipe<SendContext<T>>

cancellationToken CancellationToken

Returns

Task

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

Type Parameters

T

The message type

SendBatch<T>(ISendEndpoint, IEnumerable<T>, Action<SendContext<T>>, CancellationToken)

Send a message batch

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

Parameters

endpoint ISendEndpoint

The destination endpoint

messages IEnumerable<T>

callback Action<SendContext<T>>

The callback for the send context

cancellationToken CancellationToken

Returns

Task

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

Type Parameters

T

The message type

SendBatch<T>(ISendEndpoint, IEnumerable<T>, Func<SendContext<T>, Task>, CancellationToken)

Send a message batch

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

Parameters

endpoint ISendEndpoint

The destination endpoint

messages IEnumerable<T>

callback Func<SendContext<T>, Task>

The callback for the send context

cancellationToken CancellationToken

Returns

Task

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

Type Parameters

T

The message type

SendBatch<T>(ISendEndpoint, IEnumerable<T>, CancellationToken)

Send a message batch

public static Task SendBatch<T>(this ISendEndpoint endpoint, IEnumerable<T> messages, CancellationToken cancellationToken = default) where T : class

Parameters

endpoint ISendEndpoint

The destination endpoint

messages IEnumerable<T>

cancellationToken CancellationToken

Returns

Task

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

Type Parameters

T

The message type