Interface IMessageInitializer<TMessage>

Namespace

MassTransit.Initializers

Assembly

MassTransit.Abstractions.dll

A message initializer that doesn't use the input

public interface IMessageInitializer<TMessage> where TMessage : class

Type Parameters

TMessage

The message type

Methods

Create(PipeContext)

Create a message context, using context as a base for payloads, etc.

InitializeContext<TMessage> Create(PipeContext context)

Parameters

context PipeContext

Returns

InitializeContext<TMessage>

Create(CancellationToken)

Create a message context

InitializeContext<TMessage> Create(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

InitializeContext<TMessage>

Initialize(InitializeContext<TMessage>, object)

Initialize the message, using the input

Task<InitializeContext<TMessage>> Initialize(InitializeContext<TMessage> context, object input)

Parameters

context InitializeContext<TMessage>

An existing initialize message context

input object

Returns

Task<InitializeContext<TMessage>>

Initialize(object, CancellationToken)

Initialize the message, using the input

Task<InitializeContext<TMessage>> Initialize(object input, CancellationToken cancellationToken)

Parameters

input object

cancellationToken CancellationToken

Returns

Task<InitializeContext<TMessage>>

InitializeMessage(PipeContext, object, IPipe<SendContext<TMessage>>?)

Initialize the message using the input and send it to the endpoint.

Task<SendTuple<TMessage>> InitializeMessage(PipeContext context, object input, IPipe<SendContext<TMessage>>? pipe = null)

Parameters

context PipeContext

The base context

input object

The input object

pipe IPipe<SendContext<TMessage>>

Returns

Task<SendTuple<TMessage>>

InitializeMessage(PipeContext, object, object[], IPipe<SendContext<TMessage>>?)

Initialize the message using the input and send it to the endpoint.

Task<SendTuple<TMessage>> InitializeMessage(PipeContext context, object input, object[] moreInputs, IPipe<SendContext<TMessage>>? pipe = null)

Parameters

context PipeContext

The base context

input object

The input object

moreInputs object[]

Additional objects used to initialize the message

pipe IPipe<SendContext<TMessage>>

Returns

Task<SendTuple<TMessage>>

InitializeMessage(object, IPipe<SendContext<TMessage>>, CancellationToken)

Initialize the message using the input and send it to the endpoint.

Task<SendTuple<TMessage>> InitializeMessage(object input, IPipe<SendContext<TMessage>> pipe, CancellationToken cancellationToken)

Parameters

input object

The input object

pipe IPipe<SendContext<TMessage>>

cancellationToken CancellationToken

Returns

Task<SendTuple<TMessage>>