Class RabbitExchangeQueueProvisioner

Namespace

Steeltoe.Stream.Binder.Rabbit.Provisioning

Assembly

Steeltoe.Stream.Binder.RabbitMQ.dll

public class RabbitExchangeQueueProvisioner : IProvisioningProvider

Inheritance

object

RabbitExchangeQueueProvisioner

Implements

IProvisioningProvider

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

RabbitExchangeQueueProvisioner(IConnectionFactory, IOptionsMonitor<RabbitBindingsOptions>, IApplicationContext, ILogger<RabbitExchangeQueueProvisioner>)

public RabbitExchangeQueueProvisioner(IConnectionFactory connectionFactory, IOptionsMonitor<RabbitBindingsOptions> bindingsOptions, IApplicationContext applicationContext, ILogger<RabbitExchangeQueueProvisioner> logger)

Parameters

connectionFactory IConnectionFactory

bindingsOptions IOptionsMonitor<RabbitBindingsOptions>

applicationContext IApplicationContext

logger ILogger<RabbitExchangeQueueProvisioner>

RabbitExchangeQueueProvisioner(IConnectionFactory, List<IDeclarableCustomizer>, IOptionsMonitor<RabbitBindingsOptions>, IApplicationContext, ILogger<RabbitExchangeQueueProvisioner>)

public RabbitExchangeQueueProvisioner(IConnectionFactory connectionFactory, List<IDeclarableCustomizer> customizers, IOptionsMonitor<RabbitBindingsOptions> bindingsOptions, IApplicationContext applicationContext, ILogger<RabbitExchangeQueueProvisioner> logger)

Parameters

connectionFactory IConnectionFactory

customizers List<IDeclarableCustomizer>

bindingsOptions IOptionsMonitor<RabbitBindingsOptions>

applicationContext IApplicationContext

logger ILogger<RabbitExchangeQueueProvisioner>

Methods

ApplyPrefix(string, string)

public static string ApplyPrefix(string prefix, string name)

Parameters

prefix string

name string

Returns

string

CleanAutoDeclareContext(IConsumerDestination, IConsumerOptions)

public void CleanAutoDeclareContext(IConsumerDestination destination, IConsumerOptions consumerProperties)

Parameters

destination IConsumerDestination

consumerProperties IConsumerOptions

ConstructDLQName(string)

public static string ConstructDLQName(string name)

Parameters

name string

Returns

string

GetGroupedName(string, string)

protected virtual string GetGroupedName(string name, string group)

Parameters

name string

group string

Returns

string

ProvisionConsumerDestination(string, string, IConsumerOptions)

Creates the middleware destination on the physical broker for the consumer to consume data.The implementation is middleware-specific.

public IConsumerDestination ProvisionConsumerDestination(string name, string group, IConsumerOptions options)

Parameters

name string

the name of the consumer destination

group string

the consumer group

options IConsumerOptions

Returns

IConsumerDestination

the provisioned destination

ProvisionProducerDestination(string, IProducerOptions)

Creates middleware destination on the physical broker for the producer to send data. The implementation is middleware-specific.

public IProducerDestination ProvisionProducerDestination(string name, IProducerOptions options)

Parameters

name string

the name of the producer destination

options IProducerOptions

the producer options

Returns

IProducerDestination

the provisioned destination