Re: [akka-user] Detecting, in a sharded, persistent, passivated actor, that no messages are being received.

What about doing it on the read side, that could consume all tagged events. It could keep track of latest event time for each persistenceId and alert if deadline exceeded. /Patrik lör 11 nov. 2017 kl. 16:52 skrev lutzh : > Hi mailing list, > > I was wondering if anyone

Re: [akka-user] Akka stream - Framing with multiple delimiters

When thinking more about it I realize that a function ByteString => Boolean will probably not work well in the general case where the delimiter is more than one byte. Probably has be a fixed set of delimiters. /Patrik On Sat, Nov 11, 2017 at 3:27 PM, regis leray wrote: >

[akka-user] Re: Unable to run sample project on Akka Distribute data

I think the samples just aren't meant to be run like that, i.e. the message is right, there is no runnable class. You can still study the source code, and you can run the multi-node tests by entering: > multi-jvm:test Hth, Lutz Am Montag, 6. November 2017 18:00:07 UTC+1 schrieb Nagaraju

Re: [akka-user] Performance of Akka-Http 2.5.4

Hi Michael, Don't throw out Akka HTTP just yet, do your own measurements first. With maybe the exception of high frequency trading, I think you'll be ok... Am Freitag, 10. November 2017 13:32:14 UTC+1 schrieb Michael Zhong: > > That's awful, I've recently start using akka-http to write some

Re: [akka-user] Performance of Akka-Http 2.5.4

Hi Jakub, I can't download the zip file (I*m using the web interface, it tells me "The requested document, benchmark.zip (0x38bdd40db96ca part 0.1), could not be found: DOCID_NOT_FOUND") Could you maybe share the sources on Github, Bitbucket or the likes? Thanks, Lutz Am Freitag, 11.

[akka-user] Detecting, in a sharded, persistent, passivated actor, that no messages are being received.

Hi mailing list, I was wondering if anyone had some good ideas about this. Say I have an actor that receives data from some sensor, once an hour. I'm using Akka Cluster Sharding and Akka Persistence. So the message arrives, Akka will take care of restoring the actor state, processing the

Re: [akka-user] Akka stream - Framing with multiple delimiters

Oki, i will create a pull request to provide a function, good idea ! Le samedi 11 novembre 2017 03:35:28 UTC-5, Patrik Nordwall a écrit : > > You could do that by first replacing the various delimiters with one > common, in a map stage. That said, if this is typical framing requirement > we

[akka-user] configure offsets paramter while constructing ProducerMessage.Message in Akka Streams Kafka

I am using Scala 2.11 and Akka Streams Kafka 0.17. I have a *stream* where: - A Source is created using Source.actorRef . Here, the actor is scheduled to run at some regular interval and

Re: [akka-user] Help in Running Akka Distributed Data Samples

To compile and run tests you use: sbt test Perhaps start with the Akka Quickstart to get familiar with the basics: https://akka.io/try-akka/ /Patrik tors 9 nov. 2017 kl. 23:40 skrev Nagaraju Ajmeera < ajmeeranagaraj...@gmail.com>: > I am a newbie to the akka framework. I would like to

Re: [akka-user] Akka stream - Framing with multiple delimiters

You could do that by first replacing the various delimiters with one common, in a map stage. That said, if this is typical framing requirement we could perhaps add more power to the framing stage, e.g. a funtion ByteString => Boolean. That would be a good community contribution. /Patrik lör 11