Skip to content

Commit 298c48f

Browse files
ngocnhan-tran1996spring-builds
authored andcommitted
GH-3119: Add RabbitStreamTemplate.getStreamName()
Fixes: #3119 Without that issues may happen when 'streamName' variable is needed in another stage rather than initialization. Signed-off-by: Tran Ngoc Nhan <[email protected]> (cherry picked from commit 76e7415)
1 parent be22e2e commit 298c48f

File tree

2 files changed

+9
-0
lines changed

2 files changed

+9
-0
lines changed

spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/producer/RabbitStreamTemplate.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -226,6 +226,14 @@ public void setObservationConvention(RabbitStreamTemplateObservationConvention o
226226
this.observationConvention = observationConvention;
227227
}
228228

229+
/**
230+
* @return the stream name
231+
* @since 3.2.6
232+
*/
233+
public String getStreamName() {
234+
return this.streamName;
235+
}
236+
229237
@Override
230238
public MessageConverter messageConverter() {
231239
return this.messageConverter;

spring-rabbit-stream/src/test/java/org/springframework/rabbit/stream/producer/RabbitStreamTemplateTests.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -124,6 +124,7 @@ void superStream() {
124124
Producer producer = mock(Producer.class);
125125
given(pb.build()).willReturn(producer);
126126
try (RabbitStreamTemplate template = new RabbitStreamTemplate(env, "foo")) {
127+
assertThat(template.getStreamName()).isEqualTo("foo");
127128
SimpleMessageConverter messageConverter = new SimpleMessageConverter();
128129
template.setMessageConverter(messageConverter);
129130
assertThat(template.messageConverter()).isSameAs(messageConverter);

0 commit comments

Comments
 (0)