diff --git a/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/listener/StreamListenerContainer.java b/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/listener/StreamListenerContainer.java index a4d37067..07b00d66 100644 --- a/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/listener/StreamListenerContainer.java +++ b/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/listener/StreamListenerContainer.java @@ -56,6 +56,9 @@ import org.springframework.util.Assert; * @author Gary Russell * @author Christian Tzolov * @author Ngoc Nhan + * @author Artem Bilan + * @author David Horak + * * @since 2.4 * */ @@ -111,6 +114,15 @@ public class StreamListenerContainer extends ObservableListenerContainer { this.streamConverter = new DefaultStreamMessageConverter(codec); } + /** + * Get a stream name this listener is subscribed to. + * @return the stream name this listener is subscribed to. + * @since 3.2.3 + */ + public String getStreamName() { + return this.streamName; + } + /** * {@inheritDoc} * Mutually exclusive with {@link #superStream(String, String)}.