Uses of Class
org.springframework.integration.amqp.dsl.AmqpClientInboundChannelAdapterSpec

Packages that use AmqpClientInboundChannelAdapterSpec

Package	Description
org.springframework.integration.amqp.dsl	Provides AMQP Component support for the Java DSL.

Uses of AmqpClientInboundChannelAdapterSpec in org.springframework.integration.amqp.dsl

Subclasses with type arguments of type AmqpClientInboundChannelAdapterSpec in org.springframework.integration.amqp.dsl

Modifier and Type	Class	Description
class	AmqpClientInboundChannelAdapterSpec	Spec for an AmqpClientMessageProducer.

Methods in org.springframework.integration.amqp.dsl that return AmqpClientInboundChannelAdapterSpec

Modifier and Type	Method	Description
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.adviceChain(Advice... advices)	Set Advice instances to proxy message listener.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.afterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)	Add MessagePostProcessor instances to apply on just received messages.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.autoSettle(boolean autoSettle)	Set to false to propagate an acknowledgement callback into message headers for downstream flow manual settlement.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.batchReceiveTimeout(long batchReceiveTimeout)	Set a timeout in milliseconds for how long a batch gathering process should go.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.batchSize(int batchSize)	Set a number of AMQP messages to gather before producing as a single message downstream.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.consumersPerQueue(int consumersPerQueue)	Each queue runs in its own consumer; set this property to create multiple consumers for each queue.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.defaultRequeue(boolean defaultRequeue)	Set the default behavior when a message processing has failed.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.gracefulShutdownPeriod(Duration gracefulShutdownPeriod)	Set a duration for how long to wait for all the consumers to shut down successfully on listener container stop.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.headerMapper(AmqpHeaderMapper headerMapper)	Set an AmqpHeaderMapper to map request headers.
static AmqpClientInboundChannelAdapterSpec	AmqpClient.inboundChannelAdapter(org.springframework.amqp.rabbitmq.client.AmqpConnectionFactory connectionFactory, String... queueNames)	Create an initial AmqpClientInboundChannelAdapterSpec.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.initialCredits(int initialCredits)	The initial number credits to grant to the AMQP receiver.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.messageConverter(@Nullable MessageConverter messageConverter)	Set a MessageConverter to replace the default SimpleMessageConverter.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.priority(int priority)	The consumer priority.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.stateListeners(com.rabbitmq.client.amqp.Resource.StateListener... stateListeners)	Add Resource.StateListener instances to the consumer.
AmqpClientInboundChannelAdapterSpec	AmqpClientInboundChannelAdapterSpec.taskScheduler(TaskScheduler taskScheduler)	Set a TaskScheduler for monitoring batch releases.