Sample code for request/reply design by using Spring Cloud Stream

PubSub+ Event Broker
8

@marc ,

We able to send the message to different binder/VPN using streambridge with bindername and it is working. Please review below and share your feedback.

bindings:
initializer|validatorAndEnrichment|processor-in-0:
destination: TEMPS.Q
binder: atomic
group: AtomicProcessor
consumer:
concurrency: 5
atomicService1External-out-0:
destination: post/atomicservice1/response/external
binder: external
atomicService1Internal-out-0:
destination: post/atomicservice1/response/internal
binder: internal

        log.info("processor: " + msg.getPayload() +  msg.getHeaders());
        String bindingName = (String)msg.getHeaders().get("ReplyToBindingName");  // **atomicService1External-out-0**
        String payload = msg.getPayload().concat(" Added in sendRequest ");
        Message responseMsg = MessageBuilder.withPayload(payload).copyHeaders(msg.getHeaders()).build();
        streamBridge.send(bindingName, responseMsg);