You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Current implementation acks messages as soon as it pushed them downstream, which is not what I want. I need to be on control of acking each message manually, in some of downstream stages or outside the stream (e.g. in an independent actor):
Current implementation acks messages as soon as it pushed them downstream, which is not what I want. I need to be on control of acking each message manually, in some of downstream stages or outside the stream (e.g. in an independent actor):
https://github.com/AkkaNetContrib/Alpakka/blob/1a6a51c562e44143d0eb0f1cb175316494ed0d6a/Amqp/src/Akka.Streams.Amqp/AmqpSourceStage.cs#L136
Scala Alpakka was added
CommittableMessage
more that a year ago in akka/alpakka@d478a61, see discussion akka/alpakka#97https://github.com/akka/alpakka/blob/453809a489b37963dc0395ab37db20fd2963a3fe/amqp/src/main/scala/akka/stream/alpakka/amqp/AmqpSourceStage.scala#L95-L109
The text was updated successfully, but these errors were encountered: