Interface BehaviorContext<TSaga>

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

A behavior context is an event context delivered to a behavior, including the state instance

public interface BehaviorContext<TSaga> : SagaConsumeContext<TSaga>, ConsumeContext, PipeContext, MessageContext, IPublishEndpoint, IPublishObserverConnector, ISendEndpointProvider, ISendObserverConnector where TSaga : class, ISaga

Type Parameters

TSaga

The state instance type

Inherited Members

SagaConsumeContext<TSaga>.SetCompleted()

SagaConsumeContext<TSaga>.Saga

SagaConsumeContext<TSaga>.IsCompleted

ConsumeContext.HasMessageType(Type)

ConsumeContext.TryGetMessage<T>(out ConsumeContext<T>)

ConsumeContext.AddConsumeTask(Task)

ConsumeContext.RespondAsync<T>(T)

ConsumeContext.RespondAsync<T>(T, IPipe<SendContext<T>>)

ConsumeContext.RespondAsync<T>(T, IPipe<SendContext>)

ConsumeContext.RespondAsync(object)

ConsumeContext.RespondAsync(object, Type)

ConsumeContext.RespondAsync(object, IPipe<SendContext>)

ConsumeContext.RespondAsync(object, Type, IPipe<SendContext>)

ConsumeContext.RespondAsync<T>(object)

ConsumeContext.RespondAsync<T>(object, IPipe<SendContext<T>>)

ConsumeContext.RespondAsync<T>(object, IPipe<SendContext>)

ConsumeContext.Respond<T>(T)

ConsumeContext.NotifyConsumed<T>(ConsumeContext<T>, TimeSpan, string)

ConsumeContext.NotifyFaulted<T>(ConsumeContext<T>, TimeSpan, string, Exception)

ConsumeContext.ReceiveContext

ConsumeContext.SerializerContext

ConsumeContext.ConsumeCompleted

ConsumeContext.SupportedMessageTypes

PipeContext.HasPayloadType(Type)

PipeContext.TryGetPayload<T>(out T)

PipeContext.GetOrAddPayload<T>(PayloadFactory<T>)

PipeContext.AddOrUpdatePayload<T>(PayloadFactory<T>, UpdatePayloadFactory<T>)

PipeContext.CancellationToken

MessageContext.MessageId

MessageContext.RequestId

MessageContext.CorrelationId

MessageContext.ConversationId

MessageContext.InitiatorId

MessageContext.ExpirationTime

MessageContext.SourceAddress

MessageContext.DestinationAddress

MessageContext.ResponseAddress

MessageContext.FaultAddress

MessageContext.SentTime

MessageContext.Headers

MessageContext.Host

IPublishEndpoint.Publish<T>(T, CancellationToken)

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

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

IPublishEndpoint.Publish(object, CancellationToken)

IPublishEndpoint.Publish(object, IPipe<PublishContext>, CancellationToken)

IPublishEndpoint.Publish(object, Type, CancellationToken)

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

IPublishEndpoint.Publish<T>(object, CancellationToken)

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

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

IPublishObserverConnector.ConnectPublishObserver(IPublishObserver)

ISendEndpointProvider.GetSendEndpoint(Uri)

ISendObserverConnector.ConnectSendObserver(ISendObserver)

Extension Methods

RoutingSlipExtensions.Execute<T>(T, RoutingSlip)

CancelScheduledSendExtensions.CancelScheduledSend<T>(ConsumeContext, ScheduledMessage<T>)

ConsumeContextSchedulerExtensions.ScheduleSend(ConsumeContext, Uri, DateTime, object, IPipe<SendContext>, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend(ConsumeContext, Uri, DateTime, object, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend(ConsumeContext, Uri, DateTime, object, Type, IPipe<SendContext>, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend(ConsumeContext, Uri, DateTime, object, Type, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend(ConsumeContext, Uri, TimeSpan, object, IPipe<SendContext>, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend(ConsumeContext, Uri, TimeSpan, object, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend(ConsumeContext, Uri, TimeSpan, object, Type, IPipe<SendContext>, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend(ConsumeContext, Uri, TimeSpan, object, Type, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend<T>(ConsumeContext, Uri, DateTime, object, IPipe<SendContext<T>>, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend<T>(ConsumeContext, Uri, DateTime, object, IPipe<SendContext>, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend<T>(ConsumeContext, Uri, DateTime, object, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend<T>(ConsumeContext, Uri, DateTime, T, IPipe<SendContext<T>>, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend<T>(ConsumeContext, Uri, DateTime, T, IPipe<SendContext>, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend<T>(ConsumeContext, Uri, DateTime, T, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend<T>(ConsumeContext, Uri, TimeSpan, object, IPipe<SendContext<T>>, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend<T>(ConsumeContext, Uri, TimeSpan, object, IPipe<SendContext>, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend<T>(ConsumeContext, Uri, TimeSpan, object, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend<T>(ConsumeContext, Uri, TimeSpan, T, IPipe<SendContext<T>>, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend<T>(ConsumeContext, Uri, TimeSpan, T, IPipe<SendContext>, CancellationToken)

ConsumeContextSchedulerExtensions.ScheduleSend<T>(ConsumeContext, Uri, TimeSpan, T, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend(ConsumeContext, DateTime, object, IPipe<SendContext>, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend(ConsumeContext, DateTime, object, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend(ConsumeContext, DateTime, object, Type, IPipe<SendContext>, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend(ConsumeContext, DateTime, object, Type, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend(ConsumeContext, TimeSpan, object, IPipe<SendContext>, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend(ConsumeContext, TimeSpan, object, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend(ConsumeContext, TimeSpan, object, Type, IPipe<SendContext>, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend(ConsumeContext, TimeSpan, object, Type, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend<T>(ConsumeContext, DateTime, object, IPipe<SendContext<T>>, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend<T>(ConsumeContext, DateTime, object, IPipe<SendContext>, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend<T>(ConsumeContext, DateTime, object, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend<T>(ConsumeContext, DateTime, T, IPipe<SendContext<T>>, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend<T>(ConsumeContext, DateTime, T, IPipe<SendContext>, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend<T>(ConsumeContext, DateTime, T, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend<T>(ConsumeContext, TimeSpan, object, IPipe<SendContext<T>>, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend<T>(ConsumeContext, TimeSpan, object, IPipe<SendContext>, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend<T>(ConsumeContext, TimeSpan, object, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend<T>(ConsumeContext, TimeSpan, T, IPipe<SendContext<T>>, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend<T>(ConsumeContext, TimeSpan, T, IPipe<SendContext>, CancellationToken)

ConsumeContextSelfSchedulerExtensions.ScheduleSend<T>(ConsumeContext, TimeSpan, T, CancellationToken)

RespondAsyncExecuteExtensions.RespondAsync(ConsumeContext, object, Action<SendContext>)

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

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

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

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

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

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

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

ResponseExtensions.IsResponseAccepted<T>(ConsumeContext, bool)

RetryContextExtensions.GetRedeliveryCount(ConsumeContext)

RetryContextExtensions.GetRetryAttempt(ConsumeContext)

RetryContextExtensions.GetRetryCount(ConsumeContext)

RoutingKeyExtensions.RoutingKey(ConsumeContext)

SchedulePublishExtensions.SchedulePublish(ConsumeContext, DateTime, object, IPipe<SendContext>, CancellationToken)

SchedulePublishExtensions.SchedulePublish(ConsumeContext, DateTime, object, CancellationToken)

SchedulePublishExtensions.SchedulePublish(ConsumeContext, DateTime, object, Type, IPipe<SendContext>, CancellationToken)

SchedulePublishExtensions.SchedulePublish(ConsumeContext, DateTime, object, Type, CancellationToken)

SchedulePublishExtensions.SchedulePublish(ConsumeContext, TimeSpan, object, IPipe<SendContext>, CancellationToken)

SchedulePublishExtensions.SchedulePublish(ConsumeContext, TimeSpan, object, CancellationToken)

SchedulePublishExtensions.SchedulePublish(ConsumeContext, TimeSpan, object, Type, IPipe<SendContext>, CancellationToken)

SchedulePublishExtensions.SchedulePublish(ConsumeContext, TimeSpan, object, Type, CancellationToken)

SchedulePublishExtensions.SchedulePublish<T>(ConsumeContext, DateTime, object, IPipe<SendContext<T>>, CancellationToken)

SchedulePublishExtensions.SchedulePublish<T>(ConsumeContext, DateTime, object, IPipe<SendContext>, CancellationToken)

SchedulePublishExtensions.SchedulePublish<T>(ConsumeContext, DateTime, object, CancellationToken)

SchedulePublishExtensions.SchedulePublish<T>(ConsumeContext, DateTime, T, IPipe<SendContext<T>>, CancellationToken)

SchedulePublishExtensions.SchedulePublish<T>(ConsumeContext, DateTime, T, IPipe<SendContext>, CancellationToken)

SchedulePublishExtensions.SchedulePublish<T>(ConsumeContext, DateTime, T, CancellationToken)

SchedulePublishExtensions.SchedulePublish<T>(ConsumeContext, TimeSpan, object, IPipe<SendContext<T>>, CancellationToken)

SchedulePublishExtensions.SchedulePublish<T>(ConsumeContext, TimeSpan, object, IPipe<SendContext>, CancellationToken)

SchedulePublishExtensions.SchedulePublish<T>(ConsumeContext, TimeSpan, object, CancellationToken)

SchedulePublishExtensions.SchedulePublish<T>(ConsumeContext, TimeSpan, T, IPipe<SendContext<T>>, CancellationToken)

SchedulePublishExtensions.SchedulePublish<T>(ConsumeContext, TimeSpan, T, IPipe<SendContext>, CancellationToken)

SchedulePublishExtensions.SchedulePublish<T>(ConsumeContext, TimeSpan, T, CancellationToken)

SchedulingExtensions.GetQuartzNextScheduled(ConsumeContext)

SchedulingExtensions.GetQuartzPreviousSent(ConsumeContext)

SchedulingExtensions.GetQuartzScheduled(ConsumeContext)

SchedulingExtensions.GetQuartzSent(ConsumeContext)

SchedulingExtensions.GetSchedulingTokenId(ConsumeContext)

SendConsumeContextExecuteExtensions.Send(ConsumeContext, Uri, object, Action<SendContext>)

SendConsumeContextExecuteExtensions.Send(ConsumeContext, Uri, object, Func<SendContext, Task>)

SendConsumeContextExecuteExtensions.Send(ConsumeContext, Uri, object, Type, Action<SendContext>)

SendConsumeContextExecuteExtensions.Send(ConsumeContext, Uri, object, Type, Func<SendContext, Task>)

SendConsumeContextExecuteExtensions.Send<T>(ConsumeContext, Uri, object, Action<SendContext<T>>)

SendConsumeContextExecuteExtensions.Send<T>(ConsumeContext, Uri, object, Func<SendContext<T>, Task>)

SendConsumeContextExecuteExtensions.Send<T>(ConsumeContext, Uri, T, Action<SendContext<T>>)

SendConsumeContextExecuteExtensions.Send<T>(ConsumeContext, Uri, T, Func<SendContext<T>, Task>)

SendConsumeContextExtensions.Send(ConsumeContext, Uri, object)

SendConsumeContextExtensions.Send(ConsumeContext, Uri, object, IPipe<SendContext>)

SendConsumeContextExtensions.Send(ConsumeContext, Uri, object, Type)

SendConsumeContextExtensions.Send(ConsumeContext, Uri, object, Type, IPipe<SendContext>)

SendConsumeContextExtensions.Send<T>(ConsumeContext, Uri, object)

SendConsumeContextExtensions.Send<T>(ConsumeContext, Uri, object, IPipe<SendContext<T>>)

SendConsumeContextExtensions.Send<T>(ConsumeContext, Uri, object, IPipe<SendContext>)

SendConsumeContextExtensions.Send<T>(ConsumeContext, Uri, T)

SendConsumeContextExtensions.Send<T>(ConsumeContext, Uri, T, IPipe<SendContext<T>>)

SendConsumeContextExtensions.Send<T>(ConsumeContext, Uri, T, IPipe<SendContext>)

SendContextExtensions.GetOriginalMessageId(ConsumeContext)

SerializerContextExtensions.GetHeader(ConsumeContext, string, string?)

SerializerContextExtensions.GetHeader<T>(ConsumeContext, string, T?)

SerializerContextExtensions.GetHeader<T>(ConsumeContext, string, T?)

SerializerContextExtensions.ToDictionary<T>(ConsumeContext, T)

SerializerContextExtensions.TryGetHeader<T>(ConsumeContext, string, out T?)

SerializerContextExtensions.TryGetHeader<T>(ConsumeContext, string, out T?)

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)

PipeExtensions.GetPayload<TPayload>(PipeContext)

PipeExtensions.GetPayload<TPayload>(PipeContext, TPayload)

PipeExtensions.OneTimeSetup<T>(PipeContext, Func<T, Task>, PayloadFactory<T>)

Properties

Event

Event Event { get; }

Property Value

Event

Instance

[Obsolete("Deprecated, use Saga instead")]
TSaga Instance { get; }

Property Value

TSaga

StateMachine

StateMachine<TSaga> StateMachine { get; }

Property Value

StateMachine<TSaga>

Methods

CreateProxy(Event)

Return a proxy of the current behavior context with the specified event

BehaviorContext<TSaga> CreateProxy(Event @event)

Parameters

event Event

The event for the new context

Returns

BehaviorContext<TSaga>

CreateProxy<T>(Event<T>, T)

Return a proxy of the current behavior context with the specified event and data

BehaviorContext<TSaga, T> CreateProxy<T>(Event<T> @event, T data) where T : class

Parameters

event Event<T>

The event for the new context

data T

The data for the event

Returns

BehaviorContext<TSaga, T>

Type Parameters

T

The data type

Init<T>(object)

Task<SendTuple<T>> Init<T>(object values) where T : class

Parameters

values object

Returns

Task<SendTuple<T>>

Type Parameters

T

Raise(Event)

Raise an event on the current instance, pushing the current event on the stack

Task Raise(Event @event)

Parameters

event Event

The event to raise

Returns

Task

An awaitable Task

Raise<T>(Event<T>, T)

Raise an event on the current instance, pushing the current event on the stack

Task Raise<T>(Event<T> @event, T data) where T : class

Parameters

event Event<T>

The event to raise

data T

THe event data

Returns

Task

An awaitable Task

Type Parameters

T