diff --git a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/dsl/AmqpBaseInboundGatewaySpec.java b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/dsl/AmqpBaseInboundGatewaySpec.java index 132fd0676d..0a588ae1b4 100644 --- a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/dsl/AmqpBaseInboundGatewaySpec.java +++ b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/dsl/AmqpBaseInboundGatewaySpec.java @@ -16,7 +16,7 @@ package org.springframework.integration.amqp.dsl; -import org.springframework.amqp.rabbit.batch.BatchingStrategy; +import org.springframework.amqp.rabbit.core.support.BatchingStrategy; import org.springframework.amqp.support.converter.MessageConverter; import org.springframework.integration.amqp.inbound.AmqpInboundGateway; import org.springframework.integration.amqp.support.AmqpHeaderMapper; @@ -143,7 +143,7 @@ public class AmqpBaseInboundGatewaySpec> * Set a batching strategy to use when de-batching messages. * @param batchingStrategy the strategy to use. * @return the spec. - * @since 5.1.9 + * @since 5.2.1 * @see AmqpInboundGateway#setBatchingStrategy(BatchingStrategy) */ public S batchingStrategy(BatchingStrategy batchingStrategy) {