diff --git a/spring-integration-core/src/main/java/org/springframework/integration/endpoint/GenericMessageEndpoint.java b/spring-integration-core/src/main/java/org/springframework/integration/endpoint/GenericMessageEndpoint.java index 2a738fcdef..cff57abed8 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/endpoint/GenericMessageEndpoint.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/endpoint/GenericMessageEndpoint.java @@ -79,6 +79,10 @@ public class GenericMessageEndpoint implements MessageEndpoint { this.defaultOutputChannelName = defaultOutputChannelName; } + public String getDefaultOutputChannelName() { + return this.defaultOutputChannelName; + } + /** * Set a handler to be invoked for each consumed message. */ diff --git a/spring-integration-core/src/main/java/org/springframework/integration/endpoint/MessageEndpoint.java b/spring-integration-core/src/main/java/org/springframework/integration/endpoint/MessageEndpoint.java index a3afe2dc42..838600b595 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/endpoint/MessageEndpoint.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/endpoint/MessageEndpoint.java @@ -33,6 +33,8 @@ public interface MessageEndpoint { void setDefaultOutputChannelName(String defaultOutputChannelName); + String getDefaultOutputChannelName(); + ConsumerPolicy getConsumerPolicy(); void setChannelRegistry(ChannelRegistry channelRegistry);