[akka-user] Re: Cassandra persistence - with Cassandra 2.2.7 + akka-persistence-cassandra-0.7 + akka 2.4.8 - not working

2016-08-02 Thread Muthukumaran Kothandaraman
Just to unblock myself I had moved ahead with Cassandra 3.7. I do have some constraints in not moving to 3.x yet and have to stick to 2.x for an upcoming work. Will definitely try out the compat flag. Regards Muthu -- >> Read the docs: http://akka.io/docs/ >>

Re: [akka-user] Re: Performant SequenceID Generation

2016-08-02 Thread Patrik Nordwall
You're welcome tis 2 aug. 2016 kl. 19:40 skrev Dagny T : > > Thank you, Jim and Patrik for your responses! > > Looking into the VersionVector.scala. > Always amazed at what a good source of learning it is to see > well-structured, code-reviewed Open Source(!) > > THANKS

[akka-user] Re: from akka.persistence.journal.ReplayFilter Invalid replayed event [1] in buffer from old writer

2016-08-02 Thread Eric Swenson
I'm getting this error consistently now, and don't know why this is happening nor what to do about it. I form the persistentId this way: override def persistenceId: String = self.path.parent.parent.name + "-" + self.path.name So I don't see how I could have two persisters with the same

[akka-user] [ANNOUNCE] Akka 2.4.9-RC1 Released! (Akka HTTP Performance and Entity Streaming)

2016-08-02 Thread Konrad 'ktoso' Malawski
Dear hAkkers, We—the Akka committers—are pleased to be able to announce the availability of Akka 2.4.9-RC1. This version is focused on Akka HTTP performance improvements as well as introducing the entity streaming feature which we’ll discuss below. Highlights of the performance

[akka-user] RoundRobinPool with remote routees

2016-08-02 Thread Gabor Kolok
Hi, I am creating a router with the following code in an Actor: val router: ActorRef = { val addresses = Seq( Address("akka.tcp", "workersSystem", "localhost", 2555) ) context.actorOf( RemoteRouterConfig(RoundRobinPool(1), addresses).props(Props[ WorkerActor])) } The

[akka-user] Re: Performant SequenceID Generation

2016-08-02 Thread Dagny T
Thank you, Jim and Patrik for your responses! Looking into the VersionVector.scala. Always amazed at what a good source of learning it is to see well-structured, code-reviewed Open Source(!) THANKS again! D On Thursday, July 28, 2016 at 11:23:46 AM UTC-7, Dagny T wrote: > > > So, in the

Re: [akka-user] Re: How to read XML inputstream (with SAX parser) received by akka-http?

2016-08-02 Thread JY
I forgot to specify that flow I have to analyze weigh between 1 and 5 GB, and I have to extract the value of a dozen tags, which is why we can't load all data into memory, and that we've choose SAX :) Le mardi 2 août 2016 11:23:18 UTC+2, JY a écrit : > > In fact, (I will try to be both more

Re: [akka-user] Re: Performant SequenceID Generation

2016-08-02 Thread Patrik Nordwall
There is a public version vector implementation in akka-distributed-data, if that is what you are looking for. https://github.com/akka/akka/blob/master/akka-distributed-data/src/main/scala/akka/cluster/ddata/VersionVector.scala /Patrik fre 29 juli 2016 kl. 05:08 skrev Jim Hazen

Re: [akka-user] Cassandra persistence - with Cassandra 2.2.7 + akka-persistence-cassandra-0.7 + akka 2.4.8 - not working

2016-08-02 Thread Patrik Nordwall
Have you tried version 0.17 with the compat flag described in the readme? https://github.com/akka/akka-persistence-cassandra/blob/master/README.md /Patrik lör 30 juli 2016 kl. 16:56 skrev Justin du coeur : > I see you got things working, which is great. I just wanted to

Re: [akka-user] Re: How to read XML inputstream (with SAX parser) received by akka-http?

2016-08-02 Thread Konrad Malawski
Yeah, that'd be good to collect usecases and demadn there. Though with SAX it won't be automagical ever, they always require manually writing the parsing AFAIR -- Konrad `ktoso` Malawski Akka @ Lightbend On 2 August 2016 at 10:29:21, André

[akka-user] Re: How to read XML inputstream (with SAX parser) received by akka-http?

2016-08-02 Thread André
Maybe you can add your use case to https://github.com/akka/akka/issues/16210. On Tuesday, August 2, 2016 at 10:12:13 AM UTC+2, JY wrote: > > I am new with AKKA and AKKA HTTP. > > I have to write a HTTP server application that reads a lot very big XML > data flows (via HTTP PUT method) and

[akka-user] How to read XML inputstream (with SAX parser) received by akka-http?

2016-08-02 Thread JY
I am new with AKKA and AKKA HTTP. I have to write a HTTP server application that reads a lot very big XML data flows (via HTTP PUT method) and parses this Data with a SAX parser. How can I do that with akka-http? Thanx in advance for your help. -- >> Read the docs: