Class RabbitBroker

An IBroker implementation for RabbitMQ.

Inheritance

object

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>

RabbitBroker

Implements

IBroker

IDisposable

Inherited Members

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.ProducerEndpointType

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.ConsumerEndpointType

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.Producers

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.Consumers

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.IsConnected

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.GetProducer(IProducerEndpoint)

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.GetProducer(string)

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.AddConsumer(IConsumerEndpoint)

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.ConnectAsync()

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.DisconnectAsync()

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.Dispose()

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.InstantiateProducer(RabbitProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider)

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.InstantiateConsumer(RabbitConsumerEndpoint, IBrokerBehaviorsProvider<IConsumerBehavior>, IServiceProvider)

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.ConnectAsync(IReadOnlyCollection<IProducer>, IReadOnlyCollection<IConsumer>)

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.DisconnectAsync(IReadOnlyCollection<IProducer>, IReadOnlyCollection<IConsumer>)

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.Dispose(bool)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Silverback.Messaging.Broker

Assembly: Silverback.Integration.RabbitMQ.dll

Syntax

public class RabbitBroker : Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>, IBroker, IDisposable

Constructors

RabbitBroker(IServiceProvider)

Initializes a new instance of the RabbitBroker class.

Declaration

public RabbitBroker(IServiceProvider serviceProvider)

Parameters

Type	Name	Description
IServiceProvider	serviceProvider	The IServiceProvider to be used to resolve the required services.

Methods

InstantiateConsumer(RabbitConsumerEndpoint, IBrokerBehaviorsProvider<IConsumerBehavior>, IServiceProvider)

Returns a new instance of IConsumer to subscribe to the specified endpoint.

Declaration

protected override IConsumer InstantiateConsumer(RabbitConsumerEndpoint endpoint, IBrokerBehaviorsProvider<IConsumerBehavior> behaviorsProvider, IServiceProvider serviceProvider)

Parameters

Type	Name	Description
RabbitConsumerEndpoint	endpoint	The endpoint.
IBrokerBehaviorsProvider<IConsumerBehavior>	behaviorsProvider	The IBrokerBehaviorsProvider<TBehavior>.
IServiceProvider	serviceProvider	The IServiceProvider instance to be used to resolve the needed types or to be forwarded to the consumer.

Returns

Type	Description
IConsumer	The instantiated IConsumer.

Overrides

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.InstantiateConsumer(RabbitConsumerEndpoint, IBrokerBehaviorsProvider<IConsumerBehavior>, IServiceProvider)

InstantiateProducer(RabbitProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider)

Returns a new instance of IProducer to publish to the specified endpoint. The returned instance will be cached and reused for the same endpoint.

Declaration

protected override IProducer InstantiateProducer(RabbitProducerEndpoint endpoint, IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider, IServiceProvider serviceProvider)

Parameters

Type	Name	Description
RabbitProducerEndpoint	endpoint	The endpoint.
IBrokerBehaviorsProvider<IProducerBehavior>	behaviorsProvider	The IBrokerBehaviorsProvider<TBehavior>.
IServiceProvider	serviceProvider	The IServiceProvider instance to be used to resolve the needed types or to be forwarded to the consumer.

Returns

Type	Description
IProducer	The instantiated IProducer.

Overrides

Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>.InstantiateProducer(RabbitProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider)

Implements

IBroker

IDisposable