A consumer that allows you to send messages to RabbitMQ.
The RabbitConsumerConfiguration
auto-configuration provides the following bean:
Function<Message<?>, Object> rabbitConsumer
You can use rabbitConsumer
as a qualifier when injecting.
All configuration properties are prefixed with rabbit.consumer
.
For more information on the various options available, please see RabbitConsumerProperties.
A ComponentCustomizer<AmqpOutboundChannelAdapterSpec>
bean can be added in the target project to provide any custom options for the AmqpOutboundChannelAdapterSpec
configuration used by the rabbitConsumer
.
See this README where this consumer is used to create a Spring Cloud Stream application where it makes a RabbitMQ sink.