Alpakka JMS dispatcher

Akka Akka Streams & Alpakka
1

According to JMS specs ( Java Message Service(TM) 1.0.2 API Specification: Interface Session ):
“Once a connection has been started, any session with a registered message listener(s) is dedicated to the thread of control that delivers messages to it. It is erroneous for client code to use this session or any of its constituent objects from another thread of control. The only exception to this is the use of the session or connection close method.”

Does it implicate that I should use PinnedDispatcher for JMS processing with Alpakka?

2

Not quite familiar with the implementation, but a quick look suggests that it is handled internally by the connector: alpakka/JmsTxSourceStage.scala at master · akka/alpakka · GitHub

1 Like
3

Ah… yes, indeed. Thank you.