Re: [akka-user] Re: leveldb readjournal eventsByPersistenceId hangs when toSequenceNr=0

2016-08-21 Thread Aditya Prasad
Ah, thanks. That seems to confirm another suspicion of mine (though perhaps it's documented somewhere): that journal numbers should start at 1, not 0(?) Nothing else, I think. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

[akka-user] Fail to override Assembly Merge Strategy in multi-jvm node test

2016-08-21 Thread Lap Ming Lee
I am having trouble overriding the merge strategy for a dependency. The problem stems from the cassandra dependency rely on separate netty modules val akkaCassandra = "com.typesafe.akka" %% "akka-persistence-cassandra" % "0.17" If I run the graph-dependency, it outputs: |

Re: [akka-user] Re: leveldb readjournal eventsByPersistenceId hangs when toSequenceNr=0

2016-08-21 Thread Patrik Nordwall
It should terminate once it has arrived at or passed toSequenceNr. Otherwise I see no point in that parameter. toSeqNr=0 is an obvious boundary case, where it can terminate immediately. Anything else? /Patrik sön 21 aug. 2016 kl. 18:10 skrev Aditya Prasad : > On Sun, Aug

Re: [akka-user] Re: leveldb readjournal eventsByPersistenceId hangs when toSequenceNr=0

2016-08-21 Thread Aditya Prasad
On Sun, Aug 21, 2016 at 9:10 AM, Aditya Prasad wrote: > Thanks Patrick. > Sorry... thanks *Patrik*. > What are the more general conditions under which the stream should > terminate? > > I've come to appreciate the behavior that the stream terminates once it > has arrived at

Re: [akka-user] Re: leveldb readjournal eventsByPersistenceId hangs when toSequenceNr=0

2016-08-21 Thread Aditya Prasad
Thanks Patrick. What are the more general conditions under which the stream should terminate? I've come to appreciate the behavior that the stream terminates once it has arrived at or passed toSequenceNr. I wrote a tentative PR for the JDBC impl:

Re: [akka-user] Cluster Metrics on Windows

2016-08-21 Thread Chris Van Vranken
I've created the issue here: https://github.com/akka/akka/issues/21240 Chris On Sun, Aug 21, 2016 at 3:28 AM, Endre Varga wrote: > Hi Chris, > > Thank you for all this, very valuable information! Can you please file a > ticket on the repo for further discussions to

Re: [akka-user] Re: leveldb readjournal eventsByPersistenceId hangs when toSequenceNr=0

2016-08-21 Thread Patrik Nordwall
I think it makes sense to complete the stream when it's know that there will be no events matching toSequenceNr. There is an effort to write a TCK for Persistence Query https://github.com/akka/akka/pull/20807 Unfortunately the PR has been inactive for a while now. It would be great if community

Re: [akka-user] [akka-streams] Wrapping one flow with another while keeping the inner's materialized value

2016-08-21 Thread Itamar Ravid
Very interesting - thanks for the quick reply! I'll look into that. And yes, there does exist a timing stage in akka-streams-contrib which solves this problem by measuring the time between elements, but this was more of an 'educational' question :-) On Friday, August 19, 2016 at 7:16:54 PM

Re: [akka-user] Cluster Metrics on Windows

2016-08-21 Thread Endre Varga
Hi Chris, Thank you for all this, very valuable information! Can you please file a ticket on the repo for further discussions to not have this accidentally lost? -Endre On Sun, Aug 21, 2016 at 1:06 AM, Chris Van Vranken < cessationoft...@gmail.com> wrote: > Someone responded to me in the