Interface JobContext

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public interface JobContext : PipeContext, MessageContext, ISendEndpointProvider, ISendObserverConnector, IPublishEndpoint, IPublishObserverConnector

Inherited Members

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

ISendEndpointProvider.GetSendEndpoint(Uri)

ISendObserverConnector.ConnectSendObserver(ISendObserver)

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)

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)

RoutingSlipExtensions.Execute<T>(T, RoutingSlip)

PipeExtensions.GetPayload<TPayload>(PipeContext)

PipeExtensions.GetPayload<TPayload>(PipeContext, TPayload)

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

Properties

AttemptId

Guid AttemptId { get; }

Property Value

Guid

ElapsedTime

TimeSpan ElapsedTime { get; }

Property Value

TimeSpan

JobId

Guid JobId { get; }

Property Value

Guid

RetryAttempt

int RetryAttempt { get; }

Property Value

int

Methods

NotifyCanceled(string?)

Task NotifyCanceled(string? reason = null)

Parameters

reason string

Returns

Task

NotifyCompleted()

Task NotifyCompleted()

Returns

Task

NotifyFaulted(Exception, TimeSpan?)

Task NotifyFaulted(Exception exception, TimeSpan? delay = null)

Parameters

exception Exception

delay TimeSpan?

Returns

Task

NotifyStarted()

Task NotifyStarted()

Returns

Task