Cannot subscribe to a system category stream

EventStore / EventStore.JVM

Event Store JVM Client

https://geteventstore.com

BSD 3-Clause "New" or "Revised" License

223 stars 40 forks source link

Cannot subscribe to a system category stream #92

Open DStranger opened 7 years ago

DStranger commented 7 years ago

I have the system '$by_category' projection running, thus, there's a stream for each category, looking like '$ce-something'. But when I try to subscribe to it, I get an error:

eventstore.tcp.ConnectionActor - Cannot deliver SubscribeToStreamCompleted(9834711395,Some(EventNumber(13))), client not found for correlationId: 55cc4281-00b5-4b17-a591-92ce4d47aab1, unsubscribing

Am I missing something? I'm using version 4.1.1.

t3hnar commented 7 years ago

@DStranger could you please post your code snippet ?

DStranger commented 7 years ago

@t3hnar

val publisher = esConnection
    .streamPublisher(EventStream.Id("$ce-something"), offset)
Source.fromPublisher(publisher)
...

ahjohannessen commented 6 years ago

@DStranger did you try making publisher a def instead of val ?

shaan1337 commented 6 years ago

@t3hnar we have a similar case for one of our customers:

[WARN] [07/15/2018 21:36:55.998] [Viewpopulator-akka.actor.default-dispatcher-4] [akka://Viewpopulator/user/$b] Cannot deliver SubscribeToStreamCompleted(12638592751,Some(EventNumber(90))), client not found for correlationId: 64656a85-5fdc-4419-8b10-57eb6fa6f1ab, unsubscribing

do you have any idea about what the issue could be?