alpakka
alpakka copied to clipboard
JMS: Provide a possibility to read the JMSMessageId after sending in JmsSinkStage
The jms provider creates and sets the JMSMessageId to the jms message, which was sent. This JmsMessageId could be used as message selector for incoming replies. The communication scenario would be:
-
Client sent message via JmsSinkStage
-
Server receives message and send and reply back to the client, where the JMSMessageId of received message is used as JMSCorrelationId for the replied message.
-
Client uses the JmsMessageId as selector on JMSCorrelationId to receive the reply.
Therefore the JmsSinkStage should provide a possibility to read and process JMSMessageIds which are created from the jms provider.
This is part of the experiment in https://github.com/akka/alpakka/pull/2143