We've used Akka in the past to decouple different stages of the pipeline, but currently it's all very direct.