Skip to content

Latest commit

 

History

History
26 lines (13 loc) · 1.03 KB

File metadata and controls

26 lines (13 loc) · 1.03 KB

RabbitMQ Consumer

A consumer that allows you to send messages to RabbitMQ.

Beans for injection

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.

Configuration Options

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.

Tests

Other usage

See this README where this consumer is used to create a Spring Cloud Stream application where it makes a RabbitMQ sink.