Class ConsumerConfigurationObservable

Namespace

MassTransit.Configuration

Assembly

MassTransit.Abstractions.dll

public class ConsumerConfigurationObservable : Connectable<IConsumerConfigurationObserver>, IConsumerConfigurationObserver

Inheritance

object

Connectable<IConsumerConfigurationObserver>

ConsumerConfigurationObservable

Implements

IConsumerConfigurationObserver

Inherited Members

Connectable<IConsumerConfigurationObserver>.Connect(IConsumerConfigurationObserver)

Connectable<IConsumerConfigurationObserver>.ForEachAsync(Func<IConsumerConfigurationObserver, Task>)

Connectable<IConsumerConfigurationObserver>.ForEach(Action<IConsumerConfigurationObserver>)

Connectable<IConsumerConfigurationObserver>.All(Func<IConsumerConfigurationObserver, bool>)

Connectable<IConsumerConfigurationObserver>.Count

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ConsumerConfigurationObservable()

public ConsumerConfigurationObservable()

Methods

ConsumerConfigured<TConsumer>(IConsumerConfigurator<TConsumer>)

Called when a consumer is configured

public void ConsumerConfigured<TConsumer>(IConsumerConfigurator<TConsumer> configurator) where TConsumer : class

Parameters

configurator IConsumerConfigurator<TConsumer>

Type Parameters

TConsumer

ConsumerMessageConfigured<TConsumer, TMessage>(IConsumerMessageConfigurator<TConsumer, TMessage>)

Called when a consumer/message combination is configured

public void ConsumerMessageConfigured<TConsumer, TMessage>(IConsumerMessageConfigurator<TConsumer, TMessage> configurator) where TConsumer : class where TMessage : class

Parameters

configurator IConsumerMessageConfigurator<TConsumer, TMessage>

Type Parameters

TConsumer

TMessage