EventStore.JVM icon indicating copy to clipboard operation
EventStore.JVM copied to clipboard

Published 20 hours ago • verified publisher icon EventStore

Using persistent subscriptions with Akka Streams

Open evan108108 opened this issue 7 years ago • 15 comments

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

evan108108 avatar Jun 13 '17 22:06 evan108108

sure it is possible

t3hnar avatar Jun 14 '17 07:06 t3hnar

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

Kajvdh avatar Jun 16 '17 11:06 Kajvdh

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

evan108108 avatar Jun 17 '17 02:06 evan108108

@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

t3hnar avatar Jun 18 '17 19:06 t3hnar

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

evan108108 avatar Jun 19 '17 01:06 evan108108

@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.

Kajvdh avatar Jun 19 '17 06:06 Kajvdh

@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.

michielboekhoff avatar Jun 19 '17 08:06 michielboekhoff

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

evan108108 avatar Jun 19 '17 21:06 evan108108

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

michielboekhoff avatar Jun 20 '17 07:06 michielboekhoff

@michielboekhoff:> Thanks that's amazing!

evan108108 avatar Jun 20 '17 14:06 evan108108

@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.

michielboekhoff avatar Jun 26 '17 09:06 michielboekhoff

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

evan108108 avatar Jun 27 '17 11:06 evan108108

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

evan108108 avatar Apr 11 '18 01:04 evan108108

@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.

t3hnar avatar Apr 11 '18 06:04 t3hnar

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

ahjohannessen avatar Apr 12 '18 09:04 ahjohannessen