Class RabbitBroker
An IBroker implementation for RabbitMQ.
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Silverback.Messaging.Broker
Assembly: Silverback.Integration.RabbitMQ.dll
Syntax
public class RabbitBroker : Broker<RabbitProducerEndpoint, RabbitConsumerEndpoint>, IBroker, IDisposable
Constructors
| Improve this doc View sourceRabbitBroker(IServiceProvider)
Initializes a new instance of the RabbitBroker class.
Declaration
public RabbitBroker(IServiceProvider serviceProvider)
Parameters
Type | Name | Description |
---|---|---|
System.IServiceProvider | serviceProvider | The System.IServiceProvider to be used to resolve the required services. |
Methods
| Improve this doc View sourceInstantiateConsumer(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 | |
IBrokerBehaviorsProvider<IConsumerBehavior> | behaviorsProvider | |
System.IServiceProvider | serviceProvider | The System.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
Silverback.Messaging.Broker.Broker<Silverback.Messaging.RabbitProducerEndpoint, Silverback.Messaging.RabbitConsumerEndpoint>.InstantiateConsumer(Silverback.Messaging.RabbitConsumerEndpoint, Silverback.Messaging.Broker.Behaviors.IBrokerBehaviorsProvider<Silverback.Messaging.Broker.Behaviors.IConsumerBehavior>, System.IServiceProvider)
|
Improve this doc
View source
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 | |
IBrokerBehaviorsProvider<IProducerBehavior> | behaviorsProvider | |
System.IServiceProvider | serviceProvider | The System.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
Silverback.Messaging.Broker.Broker<Silverback.Messaging.RabbitProducerEndpoint, Silverback.Messaging.RabbitConsumerEndpoint>.InstantiateProducer(Silverback.Messaging.RabbitProducerEndpoint, Silverback.Messaging.Broker.Behaviors.IBrokerBehaviorsProvider<Silverback.Messaging.Broker.Behaviors.IProducerBehavior>, System.IServiceProvider)
Implements
System.IDisposable