[akka-user] Re: Akka Persistent Actor stops processing messages

I should clarify my post. My messages aren't backing up in those three queues at the same time, the problem has moved each time I've changed the actor's queuing behavior. The first time I examined a heap dump all the objects were in the mailbox of the actor. So I changed the mailbox to use a

[akka-user] How to enable tls in http://doc.akka.io/docs/akka/current/java/io-tcp.html

Hi, Can you anyone plz let me know that how to enable tls or ssl support in io tcp? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives:

[akka-user] Chunked Response handling with Akka Http?

I'd like to be able to use akka-http with chunked responses. I'd like to know if I can do the same thing in akka-http as with the playframework. The following is from playframework documentation. def index = Action { val source = Source.apply(List("kiki", "foo", "bar")) Ok.chunked(source)

[akka-user] Persisting entirely in JSON

I'm trying to write a persistence journal plugin (AsyncWriteJournal) that saves entirely in JSON. I've created a serializer that serializes to JSON and hooked that up along with my custom journal plugin, and whilst the objects I'm saving are being persisted as JSON, the PersistentRepr that wraps

[akka-user] PersistentActor Journal writes stop after a time with persistAsync

I'm having an issue where the journalBatch queue is just filling up with messages and no writes are happening to Cassandra. After examining the heap dump and thread stacks I can see that the variable Eventsourced.writeInProgress set to 'true' which prevents writes of the messages in

Re: [akka-user] Exception when AKKA cluster haven't setup

Akka version? tis 17 jan. 2017 kl. 02:53 skrev Dai Yinhua : > Hi, > > I was running a akka cluster, but when I start only one instance of the > akka application, then it will throw below exception repeatedly, can you > help to explain what is the issue and how to avoid it.

Re: [akka-user] Persisting entirely in JSON

On Mon, Jan 16, 2017 at 11:57 PM, Alan Burlison wrote: > On 16/01/17 21:22, Patrik Nordwall wrote: > > You should not serialize PersistentRepr, unless you are using a key-value >> store that can only store one single value per key. >> > > It's a flat file so the concept

Re: [akka-user] Persisting entirely in JSON

Pick a Journal which does this, simple. Akka has absolutely no control over how a given Akka Persistence Journal Plugin decides to persist things. Research the available journals and which allows to save things like this. You did not mention which datastore you're using, which is very very

Re: [akka-user] Persisting entirely in JSON

On 16/01/17 21:22, Patrik Nordwall wrote: You should not serialize PersistentRepr, unless you are using a key-value store that can only store one single value per key. It's a flat file so the concept of columns only exists insofar as I define it - which is why I was intending to serialize to

Re: [akka-user] Persisting entirely in JSON

On 16/01/17 20:45, Konrad Malawski wrote: Pick a Journal which does this, simple. Akka has absolutely no control over how a given Akka Persistence Journal Plugin decides to persist things. Research the available journals and which allows to save things like this. I have, I've been unable to

Re: [akka-user] Persisting entirely in JSON

You should not serialize PersistentRepr, unless you are using a key-value store that can only store one single value per key. Instead, grab the meta data fields from PersistentRepr and save them in separate columns. Grab the payload, serialize it, and save its bytes (the json) in a separate

[akka-user] Exception when AKKA cluster haven't setup

Hi, I was running a akka cluster, but when I start only one instance of the akka application, then it will throw below exception repeatedly, can you help to explain what is the issue and how to avoid it. [ERROR] [01/17/2017 07:54:57.033] [RTAPCluster-akka.actor.default-dispatcher-12]