Interface IMediator

Namespace

MassTransit.Mediator

Assembly

MassTransit.Abstractions.dll

public interface IMediator : ISendEndpoint, ISendObserverConnector, IPublishEndpoint, IPublishObserverConnector, IClientFactory, IConsumePipeConnector, IRequestPipeConnector, IConsumeObserverConnector, IConsumeMessageObserverConnector

Inherited Members

ISendEndpoint.Send<T>(T, CancellationToken)

ISendEndpoint.Send<T>(T, IPipe<SendContext<T>>, CancellationToken)

ISendEndpoint.Send<T>(T, IPipe<SendContext>, CancellationToken)

ISendEndpoint.Send(object, CancellationToken)

ISendEndpoint.Send(object, Type, CancellationToken)

ISendEndpoint.Send(object, IPipe<SendContext>, CancellationToken)

ISendEndpoint.Send(object, Type, IPipe<SendContext>, CancellationToken)

ISendEndpoint.Send<T>(object, CancellationToken)

ISendEndpoint.Send<T>(object, IPipe<SendContext<T>>, CancellationToken)

ISendEndpoint.Send<T>(object, IPipe<SendContext>, CancellationToken)

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)

IClientFactory.CreateRequest<T>(T, CancellationToken, RequestTimeout)

IClientFactory.CreateRequest<T>(Uri, T, CancellationToken, RequestTimeout)

IClientFactory.CreateRequest<T>(ConsumeContext, T, CancellationToken, RequestTimeout)

IClientFactory.CreateRequest<T>(ConsumeContext, Uri, T, CancellationToken, RequestTimeout)

IClientFactory.CreateRequest<T>(object, CancellationToken, RequestTimeout)

IClientFactory.CreateRequest<T>(Uri, object, CancellationToken, RequestTimeout)

IClientFactory.CreateRequest<T>(ConsumeContext, object, CancellationToken, RequestTimeout)

IClientFactory.CreateRequest<T>(ConsumeContext, Uri, object, CancellationToken, RequestTimeout)

IClientFactory.CreateRequestClient<T>(RequestTimeout)

IClientFactory.CreateRequestClient<T>(ConsumeContext, RequestTimeout)

IClientFactory.CreateRequestClient<T>(Uri, RequestTimeout)

IClientFactory.CreateRequestClient<T>(ConsumeContext, Uri, RequestTimeout)

IClientFactory.Context

IConsumePipeConnector.ConnectConsumePipe<T>(IPipe<ConsumeContext<T>>)

IConsumePipeConnector.ConnectConsumePipe<T>(IPipe<ConsumeContext<T>>, ConnectPipeOptions)

IRequestPipeConnector.ConnectRequestPipe<T>(Guid, IPipe<ConsumeContext<T>>)

IConsumeObserverConnector.ConnectConsumeObserver(IConsumeObserver)

IConsumeMessageObserverConnector.ConnectConsumeMessageObserver<T>(IConsumeMessageObserver<T>)

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)

BatchProduceExtensions.SendBatch(ISendEndpoint, IEnumerable<object>, IPipe<SendContext>, CancellationToken)

BatchProduceExtensions.SendBatch(ISendEndpoint, IEnumerable<object>, Action<SendContext>, CancellationToken)

BatchProduceExtensions.SendBatch(ISendEndpoint, IEnumerable<object>, Func<SendContext, Task>, CancellationToken)

BatchProduceExtensions.SendBatch(ISendEndpoint, IEnumerable<object>, CancellationToken)

BatchProduceExtensions.SendBatch(ISendEndpoint, IEnumerable<object>, Type, IPipe<SendContext>, CancellationToken)

BatchProduceExtensions.SendBatch(ISendEndpoint, IEnumerable<object>, Type, Action<SendContext>, CancellationToken)

BatchProduceExtensions.SendBatch(ISendEndpoint, IEnumerable<object>, Type, Func<SendContext, Task>, CancellationToken)

BatchProduceExtensions.SendBatch(ISendEndpoint, IEnumerable<object>, Type, CancellationToken)

BatchProduceExtensions.SendBatch<T>(ISendEndpoint, IEnumerable<T>, IPipe<SendContext<T>>, CancellationToken)

BatchProduceExtensions.SendBatch<T>(ISendEndpoint, IEnumerable<T>, Action<SendContext<T>>, CancellationToken)

BatchProduceExtensions.SendBatch<T>(ISendEndpoint, IEnumerable<T>, Func<SendContext<T>, Task>, CancellationToken)

BatchProduceExtensions.SendBatch<T>(ISendEndpoint, IEnumerable<T>, CancellationToken)

SendExecuteExtensions.Send(ISendEndpoint, object, Action<SendContext>, CancellationToken)

SendExecuteExtensions.Send(ISendEndpoint, object, Func<SendContext, Task>, CancellationToken)

SendExecuteExtensions.Send(ISendEndpoint, object, Type, Action<SendContext>, CancellationToken)

SendExecuteExtensions.Send(ISendEndpoint, object, Type, Func<SendContext, Task>, CancellationToken)

SendExecuteExtensions.Send<T>(ISendEndpoint, object, Action<SendContext<T>>, CancellationToken)

SendExecuteExtensions.Send<T>(ISendEndpoint, object, Func<SendContext<T>, Task>, CancellationToken)

SendExecuteExtensions.Send<T>(ISendEndpoint, T, Action<SendContext<T>>, CancellationToken)

SendExecuteExtensions.Send<T>(ISendEndpoint, T, Func<SendContext<T>, Task>, CancellationToken)

MediatorRequestExtensions.SendRequest<T>(IMediator, Request<T>)