Re: [akka-user] Recovery following node failure

On 29.04.14 19:01, George Wilk wrote: Thanks, Patrik. I rebuilt my POC with akka release 2.3.2 and re-tested. I was able to recreate the scenario with in-flight event not being replayed after JVM crash. Here are some additional parameters and findings pertaining to my test environment: - w

Re: [akka-user] Has anyone tried akka-persistence on Android?

On 29.04.14 19:18, Oscar Vargas Torres wrote: Now it works. https://github.com/Optrak/akkaPersistenceWithAndroid Thanks. This is great, thanks a lot for sharing your experience! Cheers, Martin -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twit

[akka-user] [akka-persistence] Are there any examples around of testing Eventsourced Processors, etc?

I've not seen any in the examples (activator, etc). I looked in the tests for akka-persistence itself, but not sure what's actually necessary from that. Do I need to pull-in/create something like PersistenceSpec, etc in order to test? -- >> Read the docs: http://akka.io/docs/ >>

[akka-user] [akka-persistence] Are there any examples around of testing eventsourced processors, etc?

I've seen the PersistenceSpec, but not entirely clear on how to use it. None of the akka-persistence examples I've found (activator,etc) have actual tests in them. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/curr

Re: [akka-user] akka-persistence handling journal failures with Views

On Tuesday, April 29, 2014 5:19:20 PM UTC+2, Martin Krasser wrote: > > > This is a failure occuring in the journal which is just reported to the > view. As such it makes sense that the view doesn't throw that exception but > retry later (which only makes sense for temporary journal failures, of

Re: [akka-user] Cant send and receive other messages than Strings between AKKA actors

Hi Endre, Thanks for your reply. The weird thing is the fact that a String works as message. Can you give me a hint where to look for the internationalization configuration or how to figure out what is wrong with it? You are totally right. It should go back to the sender.. class ErrorHand

Re: [akka-user] Event re-distribution following actor/VM failure

Hi George, On Tue, Apr 29, 2014 at 7:12 PM, George Wilk wrote: > This posting is somewhat related to my earlier topic titled “Recovery > following node failure”, which focused on replay of event following > processor failure due to VM crash. Even though this question is related to > the topic o

Re: [akka-user] Recovery following node failure

Hi George, On Tue, Apr 29, 2014 at 7:01 PM, George Wilk wrote: > Thanks, Patrik. > > I rebuilt my POC with akka release 2.3.2 and re-tested. I was able to > recreate the scenario with in-flight event not being replayed after JVM > crash. Here are some additional parameters and findings pertain

Re: [akka-user] Cant send and receive other messages than Strings between AKKA actors

Hi Matthias, On Tue, Apr 29, 2014 at 7:47 PM, Matthias Heininger < muenchn...@googlemail.com> wrote: > If try to run my application which uses akka it shows me the following > error: > > play.api.i18n.Messages$MessagesParser$$anon$1: Configuration error[`=' > expected but ` > ' found] >

[akka-user] Cant send and receive other messages than Strings between AKKA actors

If try to run my application which uses akka it shows me the following error: play.api.i18n.Messages$MessagesParser$$anon$1: Configuration error[`=' expected but ` ' found] at play.api.i18n.Messages$MessagesParser.parse(Messages.scala:219) ~[play_2.10-2.2.1.jar:2.2.1] at play.a

Re: [akka-user] Recovery following node failure

Thanks, Patrik. I rebuilt my POC with akka release 2.3.2 and re-tested. I was able to recreate the scenario with in-flight event not being replayed after JVM crash. Here are some additional parameters and findings pertaining to my test environment: - we use channels to pass command from spray

[akka-user] Event re-distribution following actor/VM failure

This posting is somewhat related to my earlier topic titled “Recovery following node failure”, which focused on replay of event following processor failure due to VM crash. Even though this question is related to the topic of recovery from failure, it is framed in context of on-the-fly redistr

Re: [akka-user] Has anyone tried akka-persistence on Android?

Now it works. https://github.com/Optrak/akkaPersistenceWithAndroid Thanks. -- >> 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/gr

Re: [akka-user] remote address of an actor

If you use akka-cluster, you can get the `Address` of the "current" node with `Cluster.selfAddress`. Heiko On Tue, Apr 29, 2014 at 6:42 PM, Sam Halliday wrote: > Hi all, > > I am migrating code (that uses akka 2.0.5), which requires an ActorPath > for any given actor that will work remotely. Th

[akka-user] remote address of an actor

Hi all, I am migrating code (that uses akka 2.0.5), which requires an ActorPath for any given actor that will work remotely. This is toString'ed and passed to a new java process (on an arbitrary remote machine) that can call home. This code used to work: def remotePath(ref: ActorRef)(implici

Re: [akka-user] akka-persistence handling journal failures with Views

On 29.04.14 17:00, Jacek Dąbrowski wrote: I've expressed it in the wrong way: The exceptions are obviously my fault (Replay failure java.io.InvalidClassException local class incompatible: stream classdesc serialVersionUID = -7798536210032631982, local class serialVersionUID = -42741879020742

Re: [akka-user] akka-persistence handling journal failures with Views

I've expressed it in the wrong way: The exceptions are obviously my fault (Replay failure java.io.InvalidClassException local class incompatible: stream classdesc serialVersionUID = -7798536210032631982, local class serialVersionUID = -4274187902074218830). But my question was - is it expected

Re: [akka-user] akka-persistence handling journal failures with Views

On 29.04.14 15:00, Jacek Dąbrowski wrote: Hi Martin, This helped, thank you very much! Glad to hear. You're welcome! Btw. after overriding onReplayFailure, I've realised that the View was constantly hitting it (deserialization exception) and it was getting swallowed silently. Is this the

Re: [akka-user] Smart Batching

Hi James, You can achieve something similar with akka.io ( http://doc.akka.io/docs/akka/2.3.2/scala/io.html). For example, while your actor waits from an Ack from a corresponding Tcp connection actor, it can batch up the all the incoming ByteStrings and send them off in one piece resulting in one

[akka-user] Smart Batching

Hi All, Has anyone used Akka to implement something akin to the 'Smart Batching' pattern that Martin Thompson describes in this blog post? http://mechanical-sympathy.blogspot.co.uk/2011/10/smart-batching.html I've seen this topic: https://groups.google.com/forum/#!topic/akka-user/todrna9GRS8/d

[akka-user] Using channels with cluster sharding

Hi all, I've been playing with the akka-cluster-sharding-scala example and I wanted to experiment with Channel communication between the Blog and the AuthorListing actor. I was wondering what is the type of channel to use here, persistent or not, as both actors are already persisted. The ques

Re: [akka-user] akka-persistence handling journal failures with Views

Hi Martin, This helped, thank you very much! Btw. after overriding onReplayFailure, I've realised that the View was constantly hitting it (deserialization exception) and it was getting swallowed silently. Is this the expected behavior? Best, -- Jacek On Tuesday, April 29, 2014 7:28:22 AM UTC

[akka-user] Re: File I/O design

Hi Christopher, Did you check Spark to do your batch operations. There processing/Transforming the data is cool. But two things to consider. How big is your data and second one is, Spark accepts input data either as Scala collections or in HDFS format. But again you m

Re: [akka-user] Steams GroupLogFile example

Ah ok, thanks. Nice work btw. On Tuesday, 29 April 2014 10:36:38 UTC+1, Akka Team wrote: > > Hi Andrew, > > That should be some version of a "flattening" operation. Currently we have > not implemented those -- not for any particular fundamental reason, just > not arrived there yet -- but they wi

Re: [akka-user] Steams GroupLogFile example

Hi Andrew, That should be some version of a "flattening" operation. Currently we have not implemented those -- not for any particular fundamental reason, just not arrived there yet -- but they will be available. Stay tuned :) -Endre On Tue, Apr 29, 2014 at 11:29 AM, Andrew Richards wrote: > Hi

[akka-user] Steams GroupLogFile example

Hi, I've been looking at the activator streams example and specifically at the GroupLogFile example. What is the correct way to merge the streams back together (using merge or concat) after using groupBy?.You'd need to go from a Flow of Producer[X] to a Producer[X] Thanks, /\ndrew -- >>

Re: [akka-user] Is UnboundedMailbox an abstract class ?

Hi, have you seen the Java documentation page for Mailbox: http://doc.akka.io/docs/akka/2.3.2/java/mailboxes.html It has some examples how to create your own mailbox. On Tue, Apr 29, 2014 at 5:15 AM, Lhfcws wrote: > Hi, all. > I'm using akka with Java. > I'm trying to extends a simple default