Re: [akka-user] Re: How to listen to events on CassandraJournalProvider ?

2017-03-20 Thread kant kodali
Hi Michael, Any idea how that that is implemented? I understand this setting "cassandra-journal.pubsub-minimum-interval" is for Akka-Cassandra-Persistence but I wonder what exactly it leverages underneath from Cassandra or Cassandra driver? Thanks, kant On Mon, Mar 13, 2017 at 1:57 AM, 'Michal

Re: [akka-user] Re: Akka HTTP path matching fundamentally broken? Surely not?

2017-03-20 Thread Alan Burlison
On 20 March 2017 at 15:57, 'Johannes Rudolph' via Akka User List wrote: > The only place where it would matter is if you complete a route from a place > where not the whole path is expected to be matched, i.e. there's still > something left in `ctx.unmatchedPath`. Is

[akka-user] Re: Akka HTTP path matching fundamentally broken? Surely not?

2017-03-20 Thread 'Johannes Rudolph' via Akka User List
Hi Alan, On Friday, March 17, 2017 at 12:25:09 PM UTC+1, Alan Burlison wrote: > > pathPrefix("root") { >concat( > pathPrefix("service1") { service1.route }, > pathPrefix("service2") { service2.route } >) > } > > That works fine with a path of say "/root/service1", but

Re: [akka-user] MergePreferred with different priorities on all inlets

2017-03-20 Thread Konrad Malawski
No, feel free to build a stage like that and contribute to akka-stream-contrib - would be nice :) -- Konrad `ktoso` Malawski Akka @ Lightbend On 20 March 2017 at 15:23:03, Sergey Sopin (sopin1...@gmail.com) wrote: Hi, Is there any way to set different

Re: [akka-user] Re: Akka HTTP path matching fundamentally broken? Surely not?

2017-03-20 Thread Alan Burlison
> I don't think a directive is the right way to do this, it needs to be > added to the existing PathMatcher DSL so it can be used with the path > and pathPrefix directives, and I'm not sure of how to do that. This seems to work: def seg(segment: String) = new PathMatcher[Unit] { def

Re: [akka-user] Re: Akka HTTP path matching fundamentally broken? Surely not?

2017-03-20 Thread Alan Burlison
On 18 March 2017 at 01:16, Daniel Stoner wrote: > I guess you have to remember that Akka-HTTP originates from Spray - and so > those choices were likely already made. (I'm sure there is a fully plausible > performance threading reason that is beyond me too hehe). Yes, I

[akka-user] MergePreferred with different priorities on all inlets

2017-03-20 Thread Sergey Sopin
Hi, Is there any way to set different priorities on different inlets in MergePreferred if it has more that two inlets? Thanks! Regards, Sergey -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] Event Stream and Routers

2017-03-20 Thread marco . campanelli
Hi Patrik, thanks for your reply. My confusion comes from the fact that, wrongly, I was expecting the Event Stream bus to behave like a Broadcast message, so the message would be received by all the routees of the router that registred with the bus. Yet, I was surprised by the fact that two

Re: [akka-user] Re: Naive question

2017-03-20 Thread 'Michal Borowiecki' via Akka User List
Hi Ryan, Kafka's log compaction is not an accurate analogy, as it simply works by preserving the last msg with a given key, removing previous messages with that key. That's not the same as the concept of snapshots in event sourcing. Cheers, Michal On 15/03/17 16:29, 'Ryan Tanner' via