From ab06c21bbc4344f804cc3f51b659dc4f498f157b Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Wed, 23 Oct 2019 11:29:52 -0400 Subject: [PATCH] Give access to AmqpOutboundEndpoint.RabbitTemplate Related to https://github.com/spring-cloud/spring-cloud-stream/pull/1824 There are some use-cases when we would like to further customize a `RabbitTemplate` encapsulated in the `AmqpOutboundEndpoint`. For this purpose there is just enough to make its getter as `public`. Also make a `AmqpHeaderMapper` available same way via `public` getter --- .../integration/amqp/outbound/AbstractAmqpOutboundEndpoint.java | 2 +- .../integration/amqp/outbound/AmqpOutboundEndpoint.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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; }