Interface CompensateContext

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public interface CompensateContext : CourierContext, ConsumeContext<RoutingSlip>, ConsumeContext, PipeContext, MessageContext, IPublishEndpoint, IPublishObserverConnector, ISendEndpointProvider, ISendObserverConnector

Inherited Members

CourierContext.TrackingNumber

CourierContext.ActivityName

CourierContext.ExecutionId

CourierContext.Timestamp

CourierContext.Elapsed

ConsumeContext<RoutingSlip>.NotifyConsumed(TimeSpan, string)

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

ConsumeContext<RoutingSlip>.Message

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

Result

Set the compensation result, which completes the activity

CompensationResult Result { get; set; }

Property Value

CompensationResult

Methods

Compensated()

The compensation was successful

CompensationResult Compensated()

Returns

CompensationResult

Compensated(IDictionary<string, object>)

The compensation was successful

CompensationResult Compensated(IDictionary<string, object> variables)

Parameters

variables IDictionary<string, object>

The variables to be updated on the routing slip

Returns

CompensationResult

Compensated(object)

The compensation was successful

CompensationResult Compensated(object values)

Parameters

values object

The variables to be updated on the routing slip

Returns

CompensationResult

Failed()

The compensation failed

CompensationResult Failed()

Returns

CompensationResult

Failed(Exception)

The compensation failed with the specified exception

CompensationResult Failed(Exception exception)

Parameters

exception Exception

Returns

CompensationResult