Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
@Outgoing("to-jms")
public PublisherBuilder<String> produceToJms() {
return ReactiveStreams.of("test1", "test2")
.map(s -> JmsMessage.builder(s)
.correlationId(UUID.randomUUID().toString())
.property("stringProp", "cool property")
.property("byteProp", 4)
.property("intProp", 5)
.onAck(() -> System.out.println("Acked!"))
.build());
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment