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 44b1ece5..563e0ef4 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 @@ -57,6 +57,7 @@ import org.springframework.util.Assert; * @author Christian Tzolov * @author Ngoc Nhan * @author Artem Bilan + * @author David Horak * * @since 2.4 * @@ -117,6 +118,15 @@ public class StreamListenerContainer extends ObservableListenerContainer { : new DefaultStreamMessageConverter(); } + /** + * 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)}.