Re: [akka-user] Persistence Query and Sharding

Cool! Are we talking in the order of seconds here? Is it dependent on polling with an adjustable interval? There’s different modes: https://github.com/akka/akka-persistence-cassandra/blob/v0.54/core/src/main/resources/reference.conf#L244 How does the offset parameter work with eventsByTag? The e

Re: [akka-user] [ANNOUNCE] ChanaMQ - an Akka based AMQP messaging broker

And when ack enabled under prefetch count 500, with limited producer rate: On Monday, July 31, 2017 at 8:40:50 PM UTC-7, Caoyuan wrote: > > For the behavior of fluctuated of send/receive rate, I tried to control > the flow of streaming source by limit the producer rate, and here's what I > got (

Re: [akka-user] [ANNOUNCE] ChanaMQ - an Akka based AMQP messaging broker

For the behavior of fluctuated of send/receive rate, I tried to control the flow of streaming source by limit the producer rate, and here's what I got (see attached chart) On Friday, July 28, 2017 at 5:31:52 AM UTC-7, √ wrote: > > Would be interesting to see if the new AffinityPool would make an

Re: [akka-user] Consuming akka-streams service via Javascript

Hi there, In general “streaming consumption" of such API can be simplified to “start working with the data before the entire transfer completes. Since it’s JSON you likely want to parse it somewhat, or select specific elements etc. AFAICS http://oboejs.com/examples is one of the streaming parsers

[akka-user] Consuming akka-streams service via Javascript

Hi, I have created a web service that sends a response in the form of a JSON stream, similar to the below code snippet from the akka-streams documentation: val route = path("tweets") { // [3] simply complete a request with a source of tweets: val tweets: Source[Tweet, NotUsed] = getTw

[akka-user] Re: how to bind each actor in a pool to a thread

Hello, I tried to use PinnedDispatcher using the following configuration (in application.conf): app { pinnedDispatcher { type = "PinnedDispatcher" executor = "thread-pool-executor" thread-pool-executor.allow-core-timeout = off thread-pool-executor {

Re: [akka-user] Persistence Query and Sharding

Thanks for the quick reply. *Eventually* all events with the given tag. > Cool! Are we talking in the order of seconds here? Is it dependent on polling with an adjustable interval? How does the offset parameter work with eventsByTag? The example in the documentation combines eventsByTag with a

Re: [akka-user] Persistence Query and Sharding

*Eventually* all events with the given tag. Note also that that stream is infinite, unlike the “currentEventsByTag” which is finite and whatever was currently visible by that tag when it was reading. — Konrad `kto.so` Malawski Akka @ Lightbend On 1 August 2

[akka-user] Persistence Query and Sharding

Hi, I'm wondering if a persistence query running in a sharded environment sees the events from all shards, or just the "local" shards. Using the Cassandra Journal Plugin. Say I have 3 cluster shards, each (for argument's sake) running in their own VM: - shard 1 - shard 2 - shard 3 Furthermore

[akka-user] Re: Strange java.lang.VerifyError with ActorSystem initialization

I just experienced the same issue this week. Turns out I had an older version of the newrelic java agent installed which caused the issue. I updated the newrelic java agent to the latest version (as of this writing ver 3.41.0) and that fixed the issue. Thanks to this thread I could stop poundi