diff --git a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AbstractAmqpOutboundEndpoint.java b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AbstractAmqpOutboundEndpoint.java index 582669d0be..97e26dc8e8 100644 --- a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AbstractAmqpOutboundEndpoint.java +++ b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AbstractAmqpOutboundEndpoint.java @@ -360,7 +360,7 @@ public abstract class AbstractAmqpOutboundEndpoint extends AbstractReplyProducin return this.exchangeNameGenerator; } - protected AmqpHeaderMapper getHeaderMapper() { + public AmqpHeaderMapper getHeaderMapper() { return this.headerMapper; } diff --git a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AmqpOutboundEndpoint.java b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AmqpOutboundEndpoint.java index b51ea63345..3b819b8915 100644 --- a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AmqpOutboundEndpoint.java +++ b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AmqpOutboundEndpoint.java @@ -98,7 +98,7 @@ public class AmqpOutboundEndpoint extends AbstractAmqpOutboundEndpoint @Override - protected RabbitTemplate getRabbitTemplate() { + public RabbitTemplate getRabbitTemplate() { return this.rabbitTemplate; }