public class RabbitExchangeQueueProvisioner extends Object implements org.springframework.context.ApplicationListener<org.springframework.amqp.rabbit.core.DeclarationExceptionEvent>, org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties>>
ProvisioningProvider
.Modifier and Type | Field and Description |
---|---|
protected org.apache.commons.logging.Log |
logger |
Constructor and Description |
---|
RabbitExchangeQueueProvisioner(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
Modifier and Type | Method and Description |
---|---|
static String |
applyPrefix(String prefix,
String name) |
void |
cleanAutoDeclareContext(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties> consumerProperties) |
static String |
constructDLQName(String name)
For binder implementations that support dead lettering, construct the name of the
dead letter entity for the underlying pipe name.
|
protected String |
groupedName(String name,
String group)
Construct a name comprised of the name and group.
|
void |
onApplicationEvent(org.springframework.amqp.rabbit.core.DeclarationExceptionEvent event) |
org.springframework.cloud.stream.provisioning.ConsumerDestination |
provisionConsumerDestination(String name,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties> properties) |
org.springframework.cloud.stream.provisioning.ProducerDestination |
provisionProducerDestination(String name,
org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties> producerProperties) |
public RabbitExchangeQueueProvisioner(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public org.springframework.cloud.stream.provisioning.ProducerDestination provisionProducerDestination(String name, org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties> producerProperties)
provisionProducerDestination
in interface org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties>>
public org.springframework.cloud.stream.provisioning.ConsumerDestination provisionConsumerDestination(String name, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties> properties)
provisionConsumerDestination
in interface org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties>>
protected final String groupedName(String name, String group)
name
- the name.group
- the group.public static String constructDLQName(String name)
name
- the name.public void cleanAutoDeclareContext(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties> consumerProperties)
public void onApplicationEvent(org.springframework.amqp.rabbit.core.DeclarationExceptionEvent event)
onApplicationEvent
in interface org.springframework.context.ApplicationListener<org.springframework.amqp.rabbit.core.DeclarationExceptionEvent>
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.