STTRS-1135 spring 3.0 support

solacecommunity · Jun 2, 2023 · a8b6529 · a8b6529
2 parents d59352b + 86f8b4b
commit a8b6529
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 11 deletions.
diff --git a/README.md b/README.md
@@ -215,7 +215,7 @@ public class PingPongConfig {
       ...
 
       return responses;
-    }, "responseMultiToRequestKnownSizeSolace");
+    }, "responseMultiToRequestKnownSizeSolace-out-0");
   }
 }
 ```
@@ -237,7 +237,7 @@ public class PingPongConfig {
       } catch (Exception e) {
         responseSink.error(new IllegalArgumentException("Business error message", e));
       }
-    }, "responseMultiToRequestRandomSizeSolace");
+    }, "responseMultiToRequestRandomSizeSolace-out-0");
   }
 }
 ```

diff --git a/...bootstarter/requestreply/service/header/RequestReplyMessageHeaderSupportServiceTests.java b/...bootstarter/requestreply/service/header/RequestReplyMessageHeaderSupportServiceTests.java
@@ -121,7 +121,7 @@ void wrap() {
 
     @Test
     void wrapList_singleResponses() {
-        Function<Message<String>, List<Message<String>>> supplier = supportService.wrapList(m -> List.of(m, m), "requestReplyRepliesDemo");
+        Function<Message<String>, List<Message<String>>> supplier = supportService.wrapList(m -> List.of(m, m), "requestReplyRepliesDemo-out-0");
 
         Message<String> m = MessageBuilder.withPayload("demo")
                 .setHeader("correlationId", "my-correlationId-my")
@@ -179,7 +179,7 @@ void wrapList_singleResponses() {
 
     @Test
     void wrapList_groupedResponses() {
-        Function<Message<String>, List<Message<String>>> supplier = supportService.wrapList(m -> List.of(m, m), "requestReplyRepliesDemo");
+        Function<Message<String>, List<Message<String>>> supplier = supportService.wrapList(m -> List.of(m, m), "requestReplyRepliesDemo-out-0");
 
         Message<String> m = MessageBuilder.withPayload("demo")
                 .setHeader("correlationId", "my-correlationId-my")
@@ -232,7 +232,7 @@ void wrapFlux_singleResponses() {
             outSink.next("first msg");
             outSink.next("second msg");
             outSink.complete();
-        },"requestReplyRepliesDemo");
+        },"requestReplyRepliesDemo-out-0");
 
         Message<String> inMsg = MessageBuilder.withPayload("demo")
                 .setHeader("correlationId", "my-correlationId-my")
@@ -322,7 +322,7 @@ void wrapFlux_groupedResponses() {
             outSink.next("first msg");
             outSink.next("second msg");
             outSink.complete();
-        },"requestReplyRepliesDemo");
+        },"requestReplyRepliesDemo-out-0");
 
         Message<String> inMsg = MessageBuilder.withPayload("demo")
                 .setHeader("correlationId", "my-correlationId-my")
@@ -394,7 +394,7 @@ void wrapFlux_groupedResponses() {
 
     @Test
     void wrapList_emptyList_shouldCreateMessageWithTotalRepliesNull() {
-        Function<Message<String>, List<Message<String>>> supplier = supportService.wrapList(m -> Collections.emptyList(), "requestReplyRepliesDemo");
+        Function<Message<String>, List<Message<String>>> supplier = supportService.wrapList(m -> Collections.emptyList(), "requestReplyRepliesDemo-out-0");
 
         Message<String> m = MessageBuilder.withPayload("demo")
                 .setHeader("correlationId", "my-correlationId-my")
@@ -431,7 +431,7 @@ void wrapList_emptyList_shouldCreateMessageWithTotalRepliesNull() {
     void wrapFlux_emptyList_shouldCreateMessageWithTotalRepliesNull() {
         Function<Flux<Message<String>>, Flux<Message<String>>> supplier = supportService.wrapFlux(
                 (payloadIn, outSink) -> outSink.complete(),
-                "requestReplyRepliesDemo"
+                "requestReplyRepliesDemo-out-0"
         );
 
         Message<String> inMsg = MessageBuilder.withPayload("demo")
@@ -530,7 +530,7 @@ void wrapList_exception_shouldReturnErrorWhenMatch() {
                 m -> {
                     throw new IllegalArgumentException("The error message");
                 },
-                "requestReplyRepliesDemo",
+                "requestReplyRepliesDemo-out-0",
                 IllegalArgumentException.class
         );
 
@@ -575,7 +575,7 @@ void wrapList_exception_shouldThrowWhenNotMatch() {
                 m -> {
                     throw new IllegalArgumentException("The error message");
                 },
-                "requestReplyRepliesDemo",
+                "requestReplyRepliesDemo-out-0",
                 NullPointerException.class
         );
 
@@ -599,7 +599,7 @@ void wrapFlux_exception() {
             outSink.next("first msg");
             outSink.error(new RuntimeException("The error message"));
             outSink.complete();
-        },"requestReplyRepliesDemo");
+        },"requestReplyRepliesDemo-out-0");
 
         Message<String> inMsg = MessageBuilder.withPayload("demo")
                 .setHeader("correlationId", "my-correlationId-my")