A consumer that allows you to send messages to RabbitMQ.
You can import RabbitConsumerConfiguration
in the application and then inject the following bean.
Function<Message<?>, Object> rabbitConsumer
You can use rabbitConsumer
as a qualifier when injecting.
All configuration properties are prefixed with rabbit
.
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.