Interface SagaConsumeContext<TSaga>

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

Consume context including the saga instance consuming the message. Note this does not expose the message type, for filters that do not care about message type.

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

Type Parameters

TSaga

The saga type

Inherited Members

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

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>)

RoutingSlipExtensions.Execute<T>(T, RoutingSlip)

Properties

IsCompleted

True if the saga has been completed, signaling that the repository may remove it.

bool IsCompleted { get; }

Property Value

bool

Saga

The saga instance for the current consume operation

TSaga Saga { get; }

Property Value

TSaga

Methods

SetCompleted()

Mark the saga instance as completed, which may remove it from the repository or archive it, etc. Once completed, a saga instance should never again be visible, even if the same CorrelationId is specified.

Task SetCompleted()

Returns

Task