Re: [akka-user] Re: When using akka-persistence-dynamodb, akka is not finding the proper avro serialzer

Is it still needed if the serialization is not using Java Serialization?? I also tried extending MyPayload with Serializable, but the error is the same. I am going to create a simple example with the issue so that maybe someone can try himself. On Wednesday, February 22, 2017 at 9:34:34 AM

[akka-user] Akka persistence cluster sharding support for 2 active-active data centers

Hi All , I have a small question for akka persistence cluster sharding support for 2 active-active data centers , is it something already supported ? in case of one of 2 data centers is down , the passivated shared can be replicated to other data center at the data level which is not an issue

Re: [akka-user] Dependency issue

DistributedData replicates everything to all nodes, so that can be the reason. You have to use cluster node roles there also. /Patrik tis 21 feb. 2017 kl. 22:16 skrev Steve Winfield < mail.stevewinfi...@gmail.com>: > Well, I'm using Akka Distributed Data on both the player and room service >

Re: [akka-user] Clarity on the term "blocking"

Everything's talking about the same principle -- the question is focus: On Wed, Feb 22, 2017 at 4:31 AM, wrote: > I read in many articles/SO posts, that the term *blocking* generally > means a caller (and therefore the thread it executes in) will *wait* until > some

[akka-user] Re: Catching "java OOM: GC overhead limit exceeded" error to stop an akka application asap

This SO questions lists a few alternatives about how to achieve that with a reasonably new JVM: http://stackoverflow.com/questions/12096403/java-shutting-down-on-out-of-memory-error On Wednesday, February 22, 2017 at 11:27:21 AM UTC+1, Hippolyte Léger wrote: > > Hello, > so I have a fairly

[akka-user] Catching "java OOM: GC overhead limit exceeded" error to stop an akka application asap

Hello, so I have a fairly large actor system on several nodes using akka-remote and a bit of a congestion problem. From time to time, some actors are overflown with messages and I get the infamous GC overhead OOM error. The problem is, when it happens the akka application doesn't stop, it keeps

Re: [akka-user] Re: Balancing Dispatcher + Custom Mailbox

Hi, I guess you are referring to this? https://gist.github.com/patriknw/5946678 On Wed, Feb 22, 2017 at 10:21 AM kalyana kannan wrote: > Hello, > > I am using Akka 2.0 & it doesn't support getContext().getMailboxSize();. > I want to get Mail Akka Box size so that i

[akka-user] AKKA system shuts down JVM

Hello We have an AKKA system in place and we are getting the error "no leveldbjni-1.8 in java.library.path", but we have the library leveldbjni-all-1.8.jar in the path. The application was working just find and suddenly it stopped working, Here is the full error: 21-Feb-2017

[akka-user] Clarity on the term "blocking"

I read in many articles/SO posts, that the term *blocking* generally means a caller (and therefore the thread it executes in) will *wait* until some data is returned (or times out maybe). In akka.io docs however it talks about *blocking* only in terms of one thread possibly causing other

Re: [akka-user] Re: When using akka-persistence-dynamodb, akka is not finding the proper avro serialzer

Quick question on your definition for "core.eventpersistence.MyPayload" did you remember to extend Serializable? Your serialization bindings look good, this is what mine look like for a single group of records since BuilderRecord is a trait that I extend. trait BuilderRecord extends Serializable

[akka-user] Custom Mail Box Sample

Akka 2.0 doesn't supports getContext().getMailboxSize() so can't able to get mail box size. Some where i read about creating custom mailbox through can get the mail box count, can someone provide JAVA sample for that? -- >> Read the docs: http://akka.io/docs/ >> Check

[akka-user] Re: When using akka-persistence-dynamodb, akka is not finding the proper avro serialzer

Hi Richard, Thankyou for answering the question. I enabled the debug level logging and saw that the custom serializer is loaded properly. So, it should be used for serialisation of the payload via akka persistence. However, looking into this error, it seems as akka is using default

Re: [akka-user] Re: Balancing Dispatcher + Custom Mailbox

Hello, I am using Akka 2.0 & it doesn't support getContext().getMailboxSize();. I want to get Mail Akka Box size so that i can stop producing request. I read somewhere like can create custom Mail Box through which can get the size. Can you provide JAVA samples for creating custom mail box?