Re: [akka-user] Timer based throttler and lifecycle events

Hi, On 28 February 2014 at 23:16:26, partyco...@gmail.com (partyco...@gmail.com) wrote: Hello, The timer based throttler actors do not have any code handling lifecycle events. What is the best fault tolerance strategy when using the timer based throttler? What is it that you want to accompl

Re: [akka-user] persistent views/cluster sharding

On Tue, Mar 4, 2014 at 5:50 PM, delasoul wrote: > sorry for the confusion:) (maybe I should not copy from former posts > without the context..) > Although you answered the wrong question the answer(s) were helpful anyway. > pls. see more inline > > > On Tuesday, 4 March 2014 16:53:24 UTC+1, Patr

[akka-user] Help needed with using Play framework and Akka - Camel

Hi, I am trying to create a web application which can be used to integrate other applications. I am not able to figure out how to define a producer endpoint which can talk to a webservice using soap. I currently have an example webservice which prints a string sent to it (to the console). I am

Re: [akka-user] akka-camel and Spring XML (newbie)

I recently stumbled across the external route definition facility introduced in Camel 2.6: https://camel.apache.org/loading-routes-from-xml-files.html. This solved my problem perfectly well, as I simply load the route definitions and add them to the DefaultContext provided by akka. This at le

Re: [akka-user] is quarantining really necessary

I am playing around with remoting, and now I'm confused because I reconstructed a situation where remote deathwatch is triggered, and yet the connection is able to be restored and actors which have been reported as Terminated become reachable again. This is contrary to my understanding that t

[akka-user] Stop an actor immediately

Hello, We have an Akka actor system running where some actors can process a short message (<10 secs) and some actors could take up to 20 minutes. At times, users might decide to cancel the process. We originally implement calling Stop on the actor, but it caused too much lag for user when long

[akka-user] [2.2.3-Scala] Confused about durable mailboxes

Perhaps I'm misunderstanding the use of durable mailboxes. Here's what I'm trying to accomplish: We have a long-running background process on one of our servers (Play Framework) which fetches data from a URL and eventually persists it in Elasticsearch based on other events in the system. Esse

Re: [akka-user] persistent views/cluster sharding

Pls forget what I wrote about using the lastProcessedSeqNr when recovering a view on restart, makes no sense -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: http://akka.io/faq/ >> Search the archives: https://groups.google.com/group/akka-user --

Re: [akka-user] Akka osgi 2.3.0-RC4 packaging error

Thanks, You're welcome :) Romain Le mardi 4 mars 2014 17:39:36 UTC+1, Björn Antonsson a écrit : > > Hi Romain, > > So there are two things here. > > First, you now need to import akka-actor yourself (previously it was > wrapped inside akka-osgi). > > Second, I only tried agains Scala 2.10. There

Re: [akka-user] Akka cluster does not dispatch messages to routess if routess are under load i.e CPU utilization is approx 85%. Is it usual?

Hi, Which version of Akka are you using? It’s generally a bad idea to perform long running tasks on the same dispatcher as the rest of the system. Either you can change your long running actors to use another dispatcher or change the remoting to use a separate dispatcher by configuring the “re

[akka-user] ANNOUNCE: Akka 2.2.4

Dear hakkers, We—the Akka committers—are pleased to be able to announce the availability of Akka 2.2.4. This is the third maintenance release of the 2.2 branch, containing documentation improvements and fixing several issues including: (remote, cluster) increased numerical precision of PhiAccru

Re: [akka-user] persistent views/cluster sharding

sorry for the confusion:) (maybe I should not copy from former posts without the context..) Although you answered the wrong question the answer(s) were helpful anyway. pls. see more inline On Tuesday, 4 March 2014 16:53:24 UTC+1, Patrik Nordwall wrote: > > > > > On Tue, Mar 4, 2014 at 10:22 AM,

Re: [akka-user] Akka osgi 2.3.0-RC4 packaging error

Hi Romain, So there are two things here. First, you now need to import akka-actor yourself (previously it was wrapped inside akka-osgi). Second, I only tried agains Scala 2.10. There seems to be a probelm with the Scala version range for the Scala 2.11 artifacts. Thanks for reporting. I’ve op

Re: [akka-user] Re: akka-camel: support for using an external camel context (defined in spring xml)

Hi mtsui, There is a test and documentation added in the pull request. It is not yet merged to master, so it isn’t available in the snapshots yet. B/ On 3 March 2014 at 16:06:20, mtsui (kawaimt...@gmail.com) wrote: Hi, Is there any documentation or examples out there to get this to work with

[akka-user] Re: Akka Clustering

hi guys, I am stuck with something again. Please help out. I am trying to pass the seed nodes from the command line like this: java *-Dakka.cluster.seed-nodes.0=akka.tcp://fumigosystem@10.147.143.42:2551*-Dakka.remote.netty.tcp.hostname=10.147.143.42 -Dakka.remote.netty.tcp.port=2551 -jar tar

Re: [akka-user] persistent views/cluster sharding

On Tue, Mar 4, 2014 at 10:22 AM, delasoul wrote: > > Hello Patrik, > > the source eventprocessor should not be the problem(as you said) - it > sends the Update msg in its eventhandler. > As I understood Martin in his first answer he suggested to use a view or > target processor to distribute even

Re: [akka-user] Akka osgi 2.3.0-RC4 packaging error

Hi Björn, First of all sorry for the delay... I have done a couple of tests. Then this is my result: In the version com.typesafe.akka:akka-osgi_2.10:2.3-M2 the content is the following:

[akka-user] Catch-all event listener

We find that misconfigured Akka Remoting endpoints (both on the client and server) are a recurrent problem for our team. Problems mostly center around getting remote actor path wrong, although there have been occurrences where the actor system name has been wrong. I'd like to write something

[akka-user] Resizing Akk Router's Pool

Hi all. In http://doc.akka.io/docs/akka/snapshot/scala/routing.html#Dynamically_Resizable_Pool described how to configure Dynamically Resizable Pool but it's not clear how to resize this pool. Should I send a kind of special message, or should invoke some method on router? Thank you. -- >>>

[akka-user] Akka cluster does not dispatch messages to routess if routess are under load i.e CPU utilization is approx 85%. Is it usual?

We are using akka cluster in our project. I send messages from one node to another and they perform cpu and memory intensive operation. Now my problem is that i am not able to dispatch further messages to nodes which are under load and it says *handshake timeout . *What should be done to avoi

Re: [akka-user] persistent views/cluster sharding

Hello Patrik, the source eventprocessor should not be the problem(as you said) - it sends the Update msg in its eventhandler. As I understood Martin in his first answer he suggested to use a view or target processor to distribute events if there is more than one interested party and I wonder h

[akka-user] lazy vals in objects received in actor

Hi I have an immutable object inherited from non-akka code with a number of lazy vals declared within in - which cause some modest amount of processing. They are not sufficiently time-consuming to warrant a separate actor/thread to calculate them but I'd rather not have to change them to defs -

Re: [akka-user] persistent views/cluster sharding

On Tue, Mar 4, 2014 at 9:40 AM, delasoul wrote: > I have just read your answer below again and wonder how you would do this >> without using channels? >> >When replaying, the view/processor would resend the same events again, > or am I missing something? > You mean when recovering the source

Re: [akka-user] persistent views/cluster sharding

> > I have just read your answer below again and wonder how you would do this > without using channels? > When replaying, the view/processor would resend the same events again, or am I missing something? > Also, it is probably not a good solution when the same event has to be > sent to mor

Re: [akka-user] persistent views/cluster sharding

On Tue, Mar 4, 2014 at 9:26 AM, delasoul wrote: > > >> A variant is to combine push and pull, which is probably what Roland was >> thinking of as "shim on top". Publish Update messages to the view using >> pub/sub (or similar). The published Update will only trigger a normal >> replay in the view

Re: [akka-user] persistent views/cluster sharding

> > A variant is to combine push and pull, which is probably what Roland was > thinking of as "shim on top". Publish Update messages to the view using > pub/sub (or similar). The published Update will only trigger a normal > replay in the view. Use pull with rather low update frequency to ensu