Publisher stops publishing events

[maciekciolek]

Hello,
I have encountered some problems with query journal. I added the ability to query events from EventsByType projection:

private def allEventsByType[T](eventType: String, fromNumberExclusive: Option[Long] = None, infinite: Boolean): Source[T, Unit] = {
    val streamId = EventStream.System("et-" + eventType)

    val publisher = connection.streamPublisher(
      streamId,
      fromNumberExclusive = fromNumberExclusive.map(value => EventNumber(value.toInt)),
      infinite = infinite,
      resolveLinkTos = true
    )

    Source.fromPublisher(publisher) map { x => serialization.deserialize[PersistentRepr](x).payload.asInstanceOf[T] }
  }

Everything works great, but sometimes the publisher stops to publish events. It occurs randomly - the stream created on the top of Source is not terminated - it does not receive any events from publisher. Is there any good way to watch the current status of subscription in order to debug it?

[t3hnar]

@maciekciolek I think you can start from setting log debug for eventstore package and maybe clone StreamPublisher.scala and add additional debugs there...