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

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/ >> Check

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

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 again! > D > > On Thursday

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

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 id.

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

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 improvement

[akka-user] RoundRobinPool with remote routees

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

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 cont

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

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 sp

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

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 : > I think what y

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

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 caution: > > On Sat, Jul

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

I for one remember SAX being hell to maintain. In a project I worked on years ago we dropped it and went with naive un-framing + JAX-B, was fast enough and still streaming. Somewhat in the direction of the today-to-be-released Akka feature about JSON Streaming does. We don't have JAX-B support in

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

In fact, (I will try to be both more specific and more generic): I have to read (via InputStream because of SAX parser) the data when the first bits are received. I'm not able to wait and load all data into memory before to use it. I can not yet find the way to do it. I need a little help :)

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

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é (andre.ruedi...@

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

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 parses

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

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: http://akka.io