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

Packages that use AmqpClientInboundGatewaySpec

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

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

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

Modifier and Type	Class	Description
class	AmqpClientInboundGatewaySpec	Spec for an AmqpClientInboundGateway.

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

Modifier and Type	Method	Description
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.adviceChain(Advice... advices)	Set Advice instances to proxy message listener.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.afterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)	Add MessagePostProcessor instances to apply on just received messages.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.autoSettle(boolean autoSettle)	Set to false to propagate an acknowledgement callback into message headers for downstream flow manual settlement.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.consumersPerQueue(int consumersPerQueue)	Each queue runs in its own consumer; set this property to create multiple consumers for each queue.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.defaultRequeue(boolean defaultRequeue)	Set the default behavior when a message processing has failed.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.gracefulShutdownPeriod(Duration gracefulShutdownPeriod)	Set a duration for how long to wait for all the consumers to shut down successfully on listener container stop.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.headerMapper(AmqpHeaderMapper headerMapper)	Set an AmqpHeaderMapper to map request and reply headers.
static AmqpClientInboundGatewaySpec	AmqpClient.inboundGateway(org.springframework.amqp.rabbitmq.client.AmqpConnectionFactory connectionFactory, String... queueNames)	Create an initial AmqpClientInboundGatewaySpec.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.initialCredits(int initialCredits)	The initial number credits to grant to the AMQP receiver.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.messageConverter(@Nullable MessageConverter messageConverter)	Set a MessageConverter to replace the default SimpleMessageConverter.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.priority(int priority)	The consumer priority.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.replyExchange(String exchange)	Set an exchange for publishing reply.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.replyPostProcessor(ReplyPostProcessor replyPostProcessor)	Set an ReplyPostProcessor to modify reply AMQP message before producing.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.replyQueue(String queue)	Set a queue for publishing reply.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.replyRoutingKey(String routingKey)	Set a routing key for publishing reply.
AmqpClientInboundGatewaySpec	AmqpClientInboundGatewaySpec.stateListeners(com.rabbitmq.client.amqp.Resource.StateListener... stateListeners)	Add Resource.StateListener instances to the consumer.