[akka-user] PersistentChannel wired behavior

hi, in my test system I have 2 processors, A, and B. In the logs below reflects this message flow: *Send persistent message DoDepositCash to A* *Send persistent message DoSubmitOrder to A,* *A receives DoSubmitOrder message and yields OrderCashLocked to a channel X and delivers to B* *B receives

Re: [akka-user] Re: Reconnect Remote Actor

On Tue, Mar 18, 2014 at 4:50 PM, Rob S wrote: > That is correct that I am not using remote deployed actors in my > application but I was attempting to run the sample code with no > modifications except for the config files. > Ok, that is good. It was just that I thought that you would find the L

Re: [akka-user] Re: Reconnect Remote Actor

On Tue, Mar 18, 2014 at 7:12 PM, Rob S wrote: > Is the problem because I can't reconnect? When I kill the connection > between two remotes on one side I can't reestablish the same connection (ip > and port). Would I need to restart the apps on both systems to resort > communications? > This is

Re: [akka-user] Cluster failover: preloaded actors

You're welcome. Anyway, I have created a ticket for the hot standby processor: https://www.assembla.com/spaces/akka/tickets/3938 That doesn't mean that we will implement it, but we will take it into consideration. Thanks for the feedback. Cheers, Patrik On Tue, Mar 18, 2014 at 8:52 PM, Eduardo F

Re: [akka-user] ActorSelection and Identify wildcard issue

On Wed, Mar 19, 2014 at 7:37 AM, Anatoliy Kaverin wrote: > I see, > but why ForwardingActor is not matched? > What do you mean? You will get 2 ActorIdentity replies, one matching and one not matching. If you are thinking about the deadletter String I guess it is similar if you send the String to

Re: [akka-user] Is the default leveldb production ready?

On Wed, Mar 19, 2014 at 5:00 AM, Eric Weise wrote: > I noticed that there is a java version of Leveldb included as the default > persistence support for Akka. Is this recommended for production? > Default is to use the native driver. You can configure it to use the pure java driver, but that is

Re: [akka-user] Akka persistent messages sent to two destinations thru one channel?

Does the following answer your question? If a processor emits more than one outbound message per inbound Persistent message it *must* use a separate channel for each outbound message to ensure that confirmations are uniquely identifiable, otherwise, at-least-once message delivery semantics do not

Re: [akka-user] Too many open files

Hi Rohit, 19 mar 2014 kl. 01:36 skrev Rohit Gupta : > Hi Roland, > > you mention a “potential leak” and “getting similar stack traces”. How and > why exactly are these stack traces emitted? Due to a crash? > > These stack traces were seen in thread dumps when the application was > running.

Re: [akka-user] Cluster failover: preloaded actors

Thanks for the new ticket! This kind of behavior is extremely useful in some cases. In our case we're moving huge Redis/HBase structures to multiple java/scala maps and the result is thousand of times faster and simple and faster to implement. We think, after reading the docs, that Akka is a ha

Re: [akka-user] ActorSelection and Identify wildcard issue

Hi Anatoliy, in general it is much easier to reason about the system if you explicitly introduce the actors to each other instead of relying on String-based lookups (which tie down your hierarchy as you now learnt). You can do that by passing an ActorRef to the constructor of a new actor or wit

Re: [akka-user] ActorSelection and Identify wildcard issue

Thanks for your help. I found a way to resolve my problem. On Wednesday, March 19, 2014 11:15:01 AM UTC+2, rkuhn wrote: > > Hi Anatoliy, > > in general it is much easier to reason about the system if you explicitly > introduce the actors to each other instead of relying on String-based > lookups

Re: [akka-user] ActorSelection and Identify wildcard issue

I see, thanks for replies!!! It looks I didn't really get how wildcard actor selection look up works, but now I got a clear picture. I have loosely coupled Actors, some of them are dynamic and later addressed by already existing ones. So, sending ActorRef is not an option. Original problem I've

Re: [akka-user] ActorSelection and Identify wildcard issue

Hi Anatoliy, 19 mar 2014 kl. 12:49 skrev Anatoliy Kaverin : > I see, > thanks for replies!!! > It looks I didn't really get how wildcard actor selection look up works, but > now I got a clear picture. > > I have loosely coupled Actors, some of them are dynamic and later addressed > by already

Re: [akka-user] PersistentChannel wired behavior

Hi Daniel, That looks strange. I tried to reproduce it, but couldn't. Please provide a minimized sample/test that we can run. Regards, Patrik On Wed, Mar 19, 2014 at 8:30 AM, Daniel Wang wrote: > hi, in my test system I have 2 processors, A, and B. In the logs below > reflects this message fl

Re: [akka-user] PersistentChannel wired behavior

Patrik, I'll try to provide a test for you :) Thank you for looking into this. On Wednesday, March 19, 2014 9:54:19 PM UTC+8, Patrik Nordwall wrote: > > Hi Daniel, > > That looks strange. I tried to reproduce it, but couldn't. Please provide > a minimized sample/test that we can run. > > Regards

Re: [akka-user] PersistentChannel wired behavior

Patrik, I forgot to mention that the actorPath of my channel destination is actually the path of a cluster-aware router who knows where exactly the remote target processor is. Maybe that's the cause? On Wednesday, March 19, 2014 9:54:19 PM UTC+8, Patrik Nordwall wrote: > > Hi Daniel, > > That

Re: [akka-user] Re: Akka persistentChannel does not delete message from Journal upon confirm

Hi Martin, I have a process that is running since last Sunday evening using the above code base(Given here) . The journal space has grown to be around 24 GB so far. I am still

Re: [akka-user] Is the default leveldb production ready?

Thanks Patrik for the reply. For some reason I thought it used the java version. Good to know though its only intended for testing. Eric On Wednesday, March 19, 2014 1:47:15 AM UTC-7, Patrik Nordwall wrote: > > > > > On Wed, Mar 19, 2014 at 5:00 AM, Eric Weise > > wrote: > >> I noticed that the

[akka-user] akka ants without STM

Hey everyone! I've been reading through the akka docs, looking at some of the example projects, and am interested in how it might help me run a large scale wildlife simulation. Without elaborating too much, I'd like to simulate a massive world that potentially is scalable across machines, with

Re: [akka-user] Design question: low latency with availability and failure tolerance

You might consider persisting to a local Kafka cluster so you can ACK quickly and with confidence and then have a separate process draining the Kafka "queue" and writing to Mongo at its leisure if that works for your use case. Kafka is persistent and replicated so you can have high confidence

[akka-user] Multi-jvm test property settings when using "sbt test"

Hi, I'm using the settings below for a multi-jvm test. After upgrading to Akka-2.3.0, I got an error stating that I needed to define the *multinode.max-nodes * system property. I added that below and now it works when I run "sbt multi-jvm:test", but I can't figure out how to add the setting so t

[akka-user] Re: Multi-jvm test property settings when using "sbt test"

Correction: The *multinode.max-nodes *property does not need to be set if "sbt multi-jvm:test" is run, but if I run "sbt test", I get: java.lang.IllegalStateException: need system property > multinode.max-nodes to be set On Wednesday, March 19, 2014 10:29:13 PM UTC+1, Allan Brighton wrote:

[akka-user] Akka Consistent Hashing Router

I have implemented two CHR where one Router has 20 routees of Actor B and another CHR router with 5 routees and both these Routers uses the Same hashMapper which uses part of the incoming message to build it. Input message: 1 2 3 4 5 Actor A calls CHR of Actor B routee 1 of Actor B gets 1 and

[akka-user] Cluster/remote pipeline strategy

Hi all. We have a system where we've implemented a pipeline strategy as follows: 1) If the number of messages pending for all actors to a remote host is more than N we flush the message queue to the net 2) If the total number of blocked threads waiting for reading is more then N we flush the m

[akka-user] Replay Intro to Akka persistence with Patrik Nordwall

I missed the live, is this going to be available on Yotube? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.com/group/akka-user ---