Skip to content

Commit 76e7415

Browse files
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]> **Auto-cherry-pick to `3.2.x`**
1 parent f12eae2 commit 76e7415

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
@@ -230,6 +230,14 @@ public void setObservationConvention(RabbitStreamTemplateObservationConvention o
230230
this.observationConvention = observationConvention;
231231
}
232232

233+
/**
234+
* @return the stream name
235+
* @since 3.2.6
236+
*/
237+
public String getStreamName() {
238+
return this.streamName;
239+
}
240+
233241
@Override
234242
public MessageConverter messageConverter() {
235243
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)