Using persistent subscriptions with Akka Streams

[evan108108]

Does anyone know if using competing consumers with persistent subscriptions is possible via the akka streams interface?

[t3hnar]

sure it is possible

[Kajvdh]

Are there any examples available that show how it is possible to subscribe to a persistent subscription with Java?

[evan108108]

I would love to see a Scala example using Akka Streams and persistent subscriptions.

[t3hnar]

@evan108108 I was wrong, looks like this is not implemented. Sorry for inconvenience.

@Kajvdh https://github.com/EventStore/EventStore.JVM/blob/master/src/main/java/eventstore/j/examples/PersistentSubscriptionExample.java

[evan108108]

Not sure what the wider community wants but I for one would love to have this feature.

[Kajvdh]

@t3hnar It is just an example on how to create, update or delete Persistent subscriptions. I am looking for an example on how I can actually subscribe to the created persistent subscription.

[michielboekhoff]

@Kajvdh

When you create the PersistentSubscriptionActor, you can specify the actor that is to receive all messages as the second argument to props. We use Scala internally, so I'm not sure how it translates to Java.

[evan108108]

@t3hnar :> Any chance you guys are working on this feature?

[michielboekhoff]

@evan108108 I could have a look at this at some point this week.

[evan108108]

@michielboekhoff:> Thanks that's amazing!

[michielboekhoff]

@evan108108 This issue is sort of blocked by #99. Right now, I'm fixing that issue first - removing all of these deprecations, so it'll work with GraphStage rather than ActorPublisher. I'll keep you updated.

[evan108108]

@michielboekhoff :> Understood. I really appreciate the update. Let me know if I can help...

[evan108108]

@t3hnar :> Any chance you guys are working on this feature?

[t3hnar]

@evan108108 I have no time on implementing new features in the client, but I'm willing to help client users to implement features on their own and merge in.
Most of the last code changes made by @ahjohannessen, maybe he can share his thoughts on this matter.

[ahjohannessen]

Seems like most of that persistent subscription code is similar to what we implemented with graph stages.