Interface IPublishEndpoint

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

A publish endpoint lets the underlying transport determine the actual endpoint to which the message is sent. For example, an exchange on RabbitMQ and a topic on Azure Service bus.

public interface IPublishEndpoint : IPublishObserverConnector

Inherited Members

IPublishObserverConnector.ConnectPublishObserver(IPublishObserver)

Extension Methods

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

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

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

BatchProduceExtensions.PublishBatch(IPublishEndpoint, IEnumerable<object>, CancellationToken)

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

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

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

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

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

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

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

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

PublishExecuteExtensions.Publish(IPublishEndpoint, object, Action<PublishContext>, CancellationToken)

PublishExecuteExtensions.Publish(IPublishEndpoint, object, Func<PublishContext, Task>, CancellationToken)

PublishExecuteExtensions.Publish(IPublishEndpoint, object, Type, Action<PublishContext>, CancellationToken)

PublishExecuteExtensions.Publish(IPublishEndpoint, object, Type, Func<PublishContext, Task>, CancellationToken)

PublishExecuteExtensions.Publish<T>(IPublishEndpoint, object, Action<PublishContext<T>>, CancellationToken)

PublishExecuteExtensions.Publish<T>(IPublishEndpoint, object, Func<PublishContext<T>, Task>, CancellationToken)

PublishExecuteExtensions.Publish<T>(IPublishEndpoint, T, Action<PublishContext<T>>, CancellationToken)

PublishExecuteExtensions.Publish<T>(IPublishEndpoint, T, Func<PublishContext<T>, Task>, CancellationToken)

Methods

Publish(object, IPipe<PublishContext>, CancellationToken)

Publishes an object as a message, using the message type specified. If the object cannot be cast to the specified message type, an exception will be thrown.

Task Publish(object message, IPipe<PublishContext> publishPipe, CancellationToken cancellationToken = default)

Parameters

message object

The message object

publishPipe IPipe<PublishContext>

cancellationToken CancellationToken

Returns

Task

Publish(object, CancellationToken)

Publishes an object as a message, using the message type specified. If the object cannot be cast to the specified message type, an exception will be thrown.

Task Publish(object message, CancellationToken cancellationToken = default)

Parameters

message object

The message object

cancellationToken CancellationToken

Returns

Task

Publish(object, Type, IPipe<PublishContext>, CancellationToken)

Publishes an object as a message, using the message type specified. If the object cannot be cast to the specified message type, an exception will be thrown.

Task Publish(object message, Type messageType, IPipe<PublishContext> publishPipe, CancellationToken cancellationToken = default)

Parameters

message object

The message object

messageType Type

The type of the message (use message.GetType() if desired)

publishPipe IPipe<PublishContext>

cancellationToken CancellationToken

Returns

Task

Publish(object, Type, CancellationToken)

Publishes an object as a message, using the message type specified. If the object cannot be cast to the specified message type, an exception will be thrown.

Task Publish(object message, Type messageType, CancellationToken cancellationToken = default)

Parameters

message object

The message object

messageType Type

The type of the message (use message.GetType() if desired)

cancellationToken CancellationToken

Returns

Task

Publish<T>(object, IPipe<PublishContext<T>>, CancellationToken)

Publish<T>(T, CancellationToken): this overload further takes an action; it allows you to set PublishContext meta-data. Also Publish<T>(T, CancellationToken).

Task Publish<T>(object values, IPipe<PublishContext<T>> publishPipe, CancellationToken cancellationToken = default) where T : class

Parameters

values object

The dictionary of values to become hydrated and published under the type of the interface.

publishPipe IPipe<PublishContext<T>>

cancellationToken CancellationToken

Returns

Task

Type Parameters

T

The type of the message to publish

Publish<T>(object, IPipe<PublishContext>, CancellationToken)

Publish<T>(T, CancellationToken): this overload further takes an action; it allows you to set PublishContext meta-data. Also Publish<T>(T, CancellationToken).

Task Publish<T>(object values, IPipe<PublishContext> publishPipe, CancellationToken cancellationToken = default) where T : class

Parameters

values object

The dictionary of values to become hydrated and published under the type of the interface.

publishPipe IPipe<PublishContext>

cancellationToken CancellationToken

Returns

Task

Type Parameters

T

The type of the message to publish

Publish<T>(object, CancellationToken)

Publish<T>(T, CancellationToken): this is a "dynamically" typed overload - give it an interface as its type parameter, and a loosely typed dictionary of values and the MassTransit underlying infrastructure will populate an object instance with the passed values. It actually does this with DynamicProxy in the background.

Task Publish<T>(object values, CancellationToken cancellationToken = default) where T : class

Parameters

values object

The dictionary of values to place in the object instance to implement the interface.

cancellationToken CancellationToken

Returns

Task

Type Parameters

T

The type of the interface or non-sealed class with all-virtual members.

Publish<T>(T, IPipe<PublishContext<T>>, CancellationToken)

Publishes a message to all subscribed consumers for the message type as specified by the generic parameter. The second parameter allows the caller to customize the outgoing publish context and set things like headers on the message.

Read up on publishing: http://readthedocs.org/docs/masstransit/en/latest/overview/publishing.html

Task Publish<T>(T message, IPipe<PublishContext<T>> publishPipe, CancellationToken cancellationToken = default) where T : class

Parameters

message T

The messages to be published

publishPipe IPipe<PublishContext<T>>

cancellationToken CancellationToken

Returns

Task

Type Parameters

T

The type of the message

Publish<T>(T, IPipe<PublishContext>, CancellationToken)

Publishes a message to all subscribed consumers for the message type as specified by the generic parameter. The second parameter allows the caller to customize the outgoing publish context and set things like headers on the message.

Read up on publishing: http://readthedocs.org/docs/masstransit/en/latest/overview/publishing.html

Task Publish<T>(T message, IPipe<PublishContext> publishPipe, CancellationToken cancellationToken = default) where T : class

Parameters

message T

The messages to be published

publishPipe IPipe<PublishContext>

cancellationToken CancellationToken

Returns

Task

Type Parameters

T

The type of the message

Publish<T>(T, CancellationToken)

Publishes a message to all subscribed consumers for the message type as specified by the generic parameter. The second parameter allows the caller to customize the outgoing publish context and set things like headers on the message.

Read up on publishing: http://readthedocs.org/docs/masstransit/en/latest/overview/publishing.html

Task Publish<T>(T message, CancellationToken cancellationToken = default) where T : class

Parameters

message T

The messages to be published

cancellationToken CancellationToken

Returns

Task

Type Parameters

T

The type of the message