Re: [akka-user] Re: Inconsistent behavior of ClusterClient.Send (akka 2.3.2) ?

On Fri, May 23, 2014 at 04:44:42PM +0200, Martynas Mickevičius wrote: > So I think this could be a bug. Could you register an issue with a > preferably multi-node test which catches this? Hi, Martynas! Thanks for confirming that this is not something local to my environment. I've created the issu

Re: [akka-user] Using ActorSelection to check if actor exists

Ok, thank you. This was the same feedback I got from my post on the Play group too. I'll give it a try. On Thursday, May 8, 2014 10:36:26 PM UTC-7, rkuhn wrote: > > Hi Tony, > > that might work most of the time ;-) The problem is that the actor’s > liveness might easily change between your Id

[akka-user] akka-remote (non-clustered) quarantines and general best practices

I've been slowly migrating an application to Akka since scala 2.10 came out and pushed me away from scala actors; sorry for any stupid questions as I'm always learning. As a general picture, the application consists of multiple long-lived JVMs communicating over ActiveMQ. The standard deploymen

Re: [akka-user] Questions/Problems/Bugs Using Akka?

Done (https://github.com/akka/akka/issues/15284) On Friday, 23 May 2014 11:54:01 UTC-7, Patrik Nordwall wrote: > > Ah, that is interesting, I think we have missed an annotation here, please > open a ticket. > > /Patrik > > 23 maj 2014 kl. 20:12 skrev Martynas Mickevičius < > martynas.m...@types

Re: [akka-user] Questions/Problems/Bugs Using Akka?

Ah, that is interesting, I think we have missed an annotation here, please open a ticket. /Patrik > 23 maj 2014 kl. 20:12 skrev Martynas Mickevičius > : > > Scala does not have checked exceptions. That is why Java compiler cannot help > you when calling a Scala method which throws a checked e

Re: [akka-user] Re: TestKit and absolute actor path path

There has been discussion about this a while ago . Basically you need to have a way to inject either ActorRef or path for actor selection. Then you can change these in tests accordingly. O

Re: [akka-user] [akka-streams]: actor producers, load balancers

> > >> Which generates an `Actor` backed producer for you (that will call your >> function), or if you need complete control you can implement a >> `Producer[T]` and give it to `Flow`: >> > > I don't think that is enough. It assumes that the elements are available > when calling the closure, ot

Re: [akka-user] [akka-streams]: actor producers, load balancers

On Friday, May 23, 2014 4:57:32 PM UTC+2, Konrad Malawski wrote: > > Cześć Adam :-) > > > - is it reasonable (thinking about reactive streams in general) to have an > actor which produces elements on-demand (instead of providing a > collection/iterator/() => as is currently supported)? As far a

Re: [akka-user] Questions/Problems/Bugs Using Akka?

Scala does not have checked exceptions. That is why Java compiler cannot help you when calling a Scala method which throws a checked exception in Java. On Fri, May 23, 2014 at 7:47 PM, Steve Ramage wrote: > Thank you for your response. > > AKKAs place in this application is to manage the concur

Re: [akka-user] Is there an 'onRecovered' hook in EventsourcedProcessor? (Implementing a 'redo transaction')

> 23 maj 2014 kl. 17:53 skrev Lawrence Wagerfield : > > That should be: > > self ! Recover() > >> On Friday, May 23, 2014 4:50:25 PM UTC+1, Lawrence Wagerfield wrote: >> Ahh brilliant :) >> >> One thing I'm struggling with though: >> >> I'm looking through the source for Processor and I don

Re: [akka-user] Questions/Problems/Bugs Using Akka?

Thank you for your response. AKKAs place in this application is to manage the concurrency involved in distributing tasks to workers, and processing them, etc... The implementation of the interface requires multi-threaded operation, and refactoring the interface introduces a huge burden on basic

Re: [akka-user] Cluster Singleton duplicated if primary seed restarted

Hello Is this situation can occur even if we have a small cluster like 3 instance and all instances in seed list? On Wednesday, 9 April 2014 08:46:38 UTC+3, Jem Mawson wrote: > > Thank you Konrad. I'm really impressed by the depth of investigation and > your explanation. > > > On 8 April 2014

[akka-user] JMX & Akka

Hello Hakkers, if I understand correctly the Typesafe console will be discontinued. As far as I am aware one thing it brought to the table was some kind of JMX support. I was wondering if the JMX support also vanishes or if it remains in some lib ? The reason I am asking is that JMX would all

[akka-user] Re: Cluster Sharding Questions

> > When scraping the router and using only sharding you will have to make > sure that your MessageExtractor is implemented in a way that achieves > desired load balancing. > Good point. Since the routees (and now the single workers) were going to be pulling data instead of getting data push

Re: [akka-user] Re: Cluster Sharding Questions

When scraping the router and using only sharding you will have to make sure that your MessageExtractor is implemented in a way that achieves desired load balancing. Good point. Since the routees (and now the single workers) were going to be pulling data instead of getting data pushed to them, I

Re: [akka-user] Re: Cluster Sharding Questions

On Fri, May 23, 2014 at 5:10 PM, Luis Medina wrote: > Hi Martynas, > > The number of distinct entryId values determines the number of workers you >> are going to have. And the number of ditinct shardId values determines the >> number of shards (groups of workers which are managed independently) t

Re: [akka-user] Is there an 'onRecovered' hook in EventsourcedProcessor? (Implementing a 'redo transaction')

That should be: self ! Recover() On Friday, May 23, 2014 4:50:25 PM UTC+1, Lawrence Wagerfield wrote: > > Ahh brilliant :) > > One thing I'm struggling with though: > > I'm looking through the source for Processor and I don't understand how > calling sender ! Recover() is optional, given the ini

Re: [akka-user] Is there an 'onRecovered' hook in EventsourcedProcessor? (Implementing a 'redo transaction')

Ahh brilliant :) One thing I'm struggling with though: I'm looking through the source for Processor and I don't understand how calling sender ! Recover() is optional, given the initial receive must be performing similar stashing/unstashing to ensure recovery is processed first. However, if t

Re: [akka-user] Is there an 'onRecovered' hook in EventsourcedProcessor? (Implementing a 'redo transaction')

and we have a ticket to support this even better: https://github.com/akka/akka/issues/13944 /Patrik On Fri, May 23, 2014 at 5:32 PM, Lawrence Wagerfield < lawre...@dmz.wagerfield.com> wrote: > Thank you, exactly what I needed :) > > > On Friday, May 23, 2014 4:30:40 PM UTC+1, Konrad Malawski wr

Re: [akka-user] [akka-streams]: actor producers, load balancers

On Fri, May 23, 2014 at 4:56 PM, Konrad 'ktoso' Malawski < konrad.malaw...@typesafe.com> wrote: > Cześć Adam :-) > > > - is it reasonable (thinking about reactive streams in general) to have an > actor which produces elements on-demand (instead of providing a > collection/iterator/() => as is curr

Re: [akka-user] Is there an 'onRecovered' hook in EventsourcedProcessor? (Implementing a 'redo transaction')

Thank you, exactly what I needed :) On Friday, May 23, 2014 4:30:40 PM UTC+1, Konrad Malawski wrote: > > Hello Lawrence! > No additional callback is provided, but there is a nice pattern that > effectively provides the same functionality: > > Please check the section of the docs about recovery st

Re: [akka-user] Is there an 'onRecovered' hook in EventsourcedProcessor? (Implementing a 'redo transaction')

Hello Lawrence! No additional callback is provided, but there is a nice pattern that effectively provides the same functionality: Please check the section of the docs about recovery status:  http://doc.akka.io/docs/akka/2.3.3/scala/persistence.html#recovery-status If you’d keep the “last msg” aro

[akka-user] Is there an 'onRecovered' hook in EventsourcedProcessor? (Implementing a 'redo transaction')

My EventsourcedProcessor needs to redo some operation if it was only half completed. The events in my system are as follows, where the first event marks the beginning of a transaction, and the latter two are mutually exclusive outcomes: UserRegistrationSubmitted UserRegistered UserRegistration

[akka-user] Re: Cluster Sharding Questions

Hi Martynas, The number of distinct entryId values determines the number of workers you > are going to have. And the number of ditinct shardId values determines the > number of shards (groups of workers which are managed independently) that > you are going to have. This makes sense. So ideall

Re: [akka-user] [akka-streams]: actor producers, load balancers

Cześć Adam :-) - is it reasonable (thinking about reactive streams in general) to have an actor which produces elements on-demand (instead of providing a collection/iterator/() => as is currently supported)? As far as I understand the current implementation, subscribers explicitly ask publishe

Re: [akka-user] Re: Inconsistent behavior of ClusterClient.Send (akka 2.3.2) ?

Hello Eugene, I have tried running your example and I get the same error. My example did not even have TaskChunk actor created by TaskSchedulerActor. After I changed the configuration to deployment { "/router_scheduler/*/router_chunkworker" { router = *round-ro

[akka-user] [akka-streams]: actor producers, load balancers

Hello, I've been looking at the akka-streams, and got two questions: - is it reasonable (thinking about reactive streams in general) to have an actor which produces elements on-demand (instead of providing a collection/iterator/() => as is currently supported)? As far as I understand the curre

Re: [akka-user] Questions/Problems/Bugs Using Akka?

Hello Steve, it seems that you are using ActorD*sl*. It is meant to be used mostly for trying things out in the REPL. I would suggest re-factoring your application to separate actors and letting Akka do the concurrency management. In that cas

Re: [akka-user] Tuning Linux for Akka

Hi Jonathan, it is hard to give advice arbitrarily. Do you see a bottleneck somewhere in your system? On Fri, May 23, 2014 at 4:42 AM, Jonathan wrote: > What are some best practices and recommendations for tuning Linux for Akka > and Akka remoting? Most systems are not setup correctly to hand

Re: [akka-user] Empty Snapshot files causes EOFException

Hi James, I've opened an issue and is investigating the problem. B/ On 23 May 2014 at 09:51:53, Björn Antonsson (bjorn.antons...@typesafe.com) wrote: Hi James, That is indeed strange. Would you mind opening an issue with this description, and maybe even a minimized reproducer? B/  On 22 Ma

Re: [akka-user] get messages back in actor test

Hi Leon, Yes, you can do that with receiveOne(d: Duration): AnyRef call. Do not hesitate to look at testingdocs and testkit example . On Fri, May 23, 2014 at 9:59 AM, Leon

Re: [akka-user] Print physical path of ActorRef instance

Hi Jonathan, you can use akka.serialization.Serialization.serializedActorPath(actorRef) which will get you akka.tcp://ClusterSystem@127.0.0.1:59905/user/clientActor#-878542148 On Fri, May 23, 2014 at 4:06 AM, Jonathan wrote: > How do you get the physical actor path (not logical path) from a

Re: [akka-user] Re: Cluster Sharding Questions

On Thu, May 22, 2014 at 11:32 PM, Luis Medina wrote: > Hi Patrik, > > I think I forgot to mention a couple of things. The workers themselves are > going to be pulling their work from RabbitMQ, they will persist it in case > of failure, and then they will start processing it through its router. >

Re: [akka-user] Re: Is it possible to use EventsourcedProcessor with FSM[S, D]?

Thanks, your feedback is well appreciated! --  Konrad 'ktoso' Malawski hAkker @ typesafe -- >> 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.

[akka-user] Re: Is it possible to use EventsourcedProcessor with FSM[S, D]?

https://github.com/akka/akka/issues/15279 On Friday, May 23, 2014 12:24:59 PM UTC+1, Konrad Malawski wrote: > > Hello Lawrence, > Mixing FSM with EventsourcedProcessor is not directly supported - going > with a child actor is easiest way to get what you need I think. > The reason it's not easy to

[akka-user] Re: Is it possible to use EventsourcedProcessor with FSM[S, D]?

Hello Lawrence, Mixing FSM with EventsourcedProcessor is not directly supported - going with a child actor is easiest way to get what you need I think. The reason it's not easy to just mix-in both FSM and EP is because they both do a lot around handling the `receive` "for you" so it may be tough

Re: [akka-user] akka-stream: how to construct a time based Flow

Great, things are moving on, this is amazing! Thanks for your quick answer. Any plan / timeline for a 0.3 akka-stream release, with this included? Or, is it possible to use the release-2.3-dev branch? Is there an artifact published somewhere (maven)? Le vendredi 23 mai 2014 11:52:42 UTC+2, Patr

Re: [akka-user] akka-stream: how to construct a time based Flow

and also https://github.com/akka/akka/pull/15245 On Fri, May 23, 2014 at 10:29 AM, Martynas Mickevičius < martynas.mickevic...@typesafe.com> wrote: > Hello, > > that is being worked on right now. Take a look at the code: > https://github.com/akka/akka/pull/15274 > > > On Fri, May 23, 2014 at 10:

Re: [akka-user] akka-stream: how to construct a time based Flow

Hello, that is being worked on right now. Take a look at the code: https://github.com/akka/akka/pull/15274 On Fri, May 23, 2014 at 10:28 AM, benq wrote: > Hi, > > In the new akka-stream (0.2), is is possible to construct a Flow that will > emit an event every time interval? > > For example, ho

[akka-user] akka-stream: how to construct a time based Flow

Hi, In the new akka-stream (0.2), is is possible to construct a Flow that will emit an event every time interval? For example, how can I build a stream that would have one random number per second? Is that possible? benq -- >> Read the docs: http://akka.io/docs/ >>

[akka-user] get messages back in actor test

Hi, Usually I do: actorRef ! SomeRequest expectMsg(SomeResponse) However I'd like to know whether I can get the last response message object like this: actorRef ! SomeRequest val resp = lastMsg() resp.propA should be (...) resp.StringProp contains "mysubstring" should be(true) Is it doable

Re: [akka-user] Empty Snapshot files causes EOFException

Hi James, That is indeed strange. Would you mind opening an issue with this description, and maybe even a minimized reproducer? B/  On 22 May 2014 at 14:50:23, James Brems (jamesbrem...@gmail.com) wrote: Hi Björn, today I found out that the root cause seems to be the length of the fully qual

Re: [akka-user] Re: sbt downloading denpendecies with wrong revisions

Also sbt 0.13.5-RC5 has been released couple of days ago with this issue fixed. On Fri, May 23, 2014 at 6:15 AM, Anthony Kilman wrote: > Ran into the same issue. Updated the project/build.properties version from > 0.13.5-RC1 to 0.13.2, worked like a charm. > > > On Tuesday, May 20, 2014 12:36:38