public class RabbitMessageChannelBinder extends org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties>,org.springframework.amqp.core.Queue,org.springframework.amqp.core.TopicExchange> implements org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,RabbitConsumerProperties,RabbitProducerProperties>
Binder implementation backed by RabbitMQ.| Constructor and Description |
|---|
RabbitMessageChannelBinder(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
org.springframework.boot.autoconfigure.amqp.RabbitProperties rabbitProperties) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
afterUnbindConsumer(String name,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties> consumerProperties) |
protected org.springframework.amqp.core.Queue |
createConsumerDestinationIfNecessary(String name,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties> properties) |
protected org.springframework.integration.core.MessageProducer |
createConsumerEndpoint(String name,
String group,
org.springframework.amqp.core.Queue destination,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties> properties) |
protected org.springframework.amqp.core.TopicExchange |
createProducerDestinationIfNecessary(String name,
org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties> producerProperties) |
protected org.springframework.messaging.MessageHandler |
createProducerMessageHandler(org.springframework.amqp.core.TopicExchange exchange,
org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties> properties) |
RabbitConsumerProperties |
getExtendedConsumerProperties(String channelName) |
RabbitProducerProperties |
getExtendedProducerProperties(String channelName) |
void |
onInit() |
void |
setAdminAddresses(String[] adminAddresses) |
void |
setCompressingPostProcessor(org.springframework.amqp.core.MessagePostProcessor compressingPostProcessor)
Set a
MessagePostProcessor to compress messages. |
void |
setDecompressingPostProcessor(org.springframework.amqp.core.MessagePostProcessor decompressingPostProcessor)
Set a
MessagePostProcessor to decompress messages. |
void |
setExtendedBindingProperties(RabbitExtendedBindingProperties extendedBindingProperties) |
void |
setNodes(String[] nodes) |
afterUnbindProducer, doBindConsumer, doBindProducerafterPropertiesSet, applyPrefix, bindConsumer, bindProducer, buildPartitionRoutingExpression, buildRetryTemplate, constructDLQName, getApplicationContext, getBeanFactory, groupedName, setApplicationContext, setCodec, setIntegrationEvaluationContextpublic RabbitMessageChannelBinder(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
org.springframework.boot.autoconfigure.amqp.RabbitProperties rabbitProperties)
public void setDecompressingPostProcessor(org.springframework.amqp.core.MessagePostProcessor decompressingPostProcessor)
MessagePostProcessor to decompress messages. Defaults to a
DelegatingDecompressingPostProcessor with its default delegates.decompressingPostProcessor - the post processor.public void setCompressingPostProcessor(org.springframework.amqp.core.MessagePostProcessor compressingPostProcessor)
MessagePostProcessor to compress messages. Defaults to a
GZipPostProcessor.compressingPostProcessor - the post processor.public void setAdminAddresses(String[] adminAddresses)
public void setNodes(String[] nodes)
public void setExtendedBindingProperties(RabbitExtendedBindingProperties extendedBindingProperties)
public void onInit()
onInit in class org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties>>public RabbitConsumerProperties getExtendedConsumerProperties(String channelName)
getExtendedConsumerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<RabbitConsumerProperties,RabbitProducerProperties>public RabbitProducerProperties getExtendedProducerProperties(String channelName)
getExtendedProducerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<RabbitConsumerProperties,RabbitProducerProperties>protected org.springframework.integration.core.MessageProducer createConsumerEndpoint(String name, String group, org.springframework.amqp.core.Queue destination, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties> properties)
createConsumerEndpoint in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties>,org.springframework.amqp.core.Queue,org.springframework.amqp.core.TopicExchange>protected void afterUnbindConsumer(String name, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties> consumerProperties)
afterUnbindConsumer in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties>,org.springframework.amqp.core.Queue,org.springframework.amqp.core.TopicExchange>protected org.springframework.amqp.core.Queue createConsumerDestinationIfNecessary(String name, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties> properties)
createConsumerDestinationIfNecessary in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties>,org.springframework.amqp.core.Queue,org.springframework.amqp.core.TopicExchange>protected org.springframework.amqp.core.TopicExchange createProducerDestinationIfNecessary(String name, org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties> producerProperties)
createProducerDestinationIfNecessary in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties>,org.springframework.amqp.core.Queue,org.springframework.amqp.core.TopicExchange>protected org.springframework.messaging.MessageHandler createProducerMessageHandler(org.springframework.amqp.core.TopicExchange exchange,
org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties> properties)
throws Exception
createProducerMessageHandler in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RabbitConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RabbitProducerProperties>,org.springframework.amqp.core.Queue,org.springframework.amqp.core.TopicExchange>ExceptionCopyright © 2016 Pivotal Software, Inc.. All rights reserved.