diff --git a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/AmqpInboundChannelAdapter.java b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/AmqpInboundChannelAdapter.java index 0788f0d1c5..8ba884b673 100644 --- a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/AmqpInboundChannelAdapter.java +++ b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/AmqpInboundChannelAdapter.java @@ -123,6 +123,11 @@ public class AmqpInboundChannelAdapter extends MessageProducerSupport implements private BatchMode batchMode = BatchMode.MESSAGES; + // TODO Remove in 6.0 + public AmqpInboundChannelAdapter(AbstractMessageListenerContainer listenerContainer) { + this((MessageListenerContainer) listenerContainer); + } + /** * Construct an instance using the provided container. * @param listenerContainer the container. diff --git a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/AmqpInboundGateway.java b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/AmqpInboundGateway.java index 7ab573923c..b478ab4376 100644 --- a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/AmqpInboundGateway.java +++ b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/AmqpInboundGateway.java @@ -101,12 +101,23 @@ public class AmqpInboundGateway extends MessagingGatewaySupport { this(listenerContainer, new RabbitTemplate(listenerContainer.getConnectionFactory()), false); } + // TODO Remove in 6.0 + /** + * Construct {@link AmqpInboundGateway} based on the provided {@link AbstractMessageListenerContainer} + * to receive request messages and {@link AmqpTemplate} to send replies. + * @param listenerContainer the {@link MessageListenerContainer} to receive AMQP messages. + * @param amqpTemplate the {@link AmqpTemplate} to send reply messages. + * @since 4.2 + */ + public AmqpInboundGateway(AbstractMessageListenerContainer listenerContainer, AmqpTemplate amqpTemplate) { + this((MessageListenerContainer) listenerContainer, amqpTemplate); + } + /** * Construct {@link AmqpInboundGateway} based on the provided {@link MessageListenerContainer} * to receive request messages and {@link AmqpTemplate} to send replies. * @param listenerContainer the {@link MessageListenerContainer} to receive AMQP messages. * @param amqpTemplate the {@link AmqpTemplate} to send reply messages. - * @since 4.2 */ public AmqpInboundGateway(MessageListenerContainer listenerContainer, AmqpTemplate amqpTemplate) { this(listenerContainer, amqpTemplate, true);