Re: [akka-user] Akka Cluster SIngleton: when is preStart() called?

2016-04-20 Thread Patrik Nordwall
r...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Akka Tech Lead Lightbend <http://www.ligh

Re: [akka-user] Re: Akka HTTP performance for short lived connections

2016-04-19 Thread Patrik Nordwall
;>>>>>>> Check the FAQ: >>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>> >>>>>>>>>> Search the archives: >>>> https://groups.google.com/group/akka-user >>>> --- >>>>

Re: [akka-user] Akka Singleton Cluster: Knowing when standby master has become primary

2016-04-17 Thread Patrik Nordwall
> To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit

Re: [akka-user] Akka Singleton Cluster: Inconsistent cluster behavior on worker restart

2016-04-17 Thread Patrik Nordwall
-- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googl

Re: [akka-user] Akka Cluster: Why Member does not have name property?

2016-04-17 Thread Patrik Nordwall
n the name of the node that came up in the cluster? > > > On Sunday, April 17, 2016 at 3:58:46 AM UTC-7, Patrik Nordwall wrote: > >> No, MemberUp is a notification that a node/ActorSystem was added to the >> cluster. >> >> You can read about ActorSystem here: >&g

Re: [akka-user] Akka Cluster: Why Member does not have name property?

2016-04-17 Thread Patrik Nordwall
nce between Member and an > Actor. Isn't ActorSystem a hierarchical group of actors? When one creates > an Actor in the ActorSystem, doesn't everyone in the system get a > notification of new actor aka MemberUp? > > > On Saturday, April 16, 2016 at 11:22:02 AM UTC-7, Patr

Re: [akka-user] Akka Cluster: Why Member does not have name property?

2016-04-16 Thread Patrik Nordwall
I think there is some misunderstanding. Member corresponds to an ActorSystem, not an actor. /Patrik lör 16 apr. 2016 kl. 18:23 skrev Prasanna Thirumalai : > When I subscribe of cluster events, the 'Member' entity does not have any > name property where this property is same as given to the corre

Re: [akka-user] Re: Why does TestKit maintain the same ActorSystem between tests?

2016-04-15 Thread Patrik Nordwall
With persistence you need to clean the data, eg remove files if you use leveldb for testing. We have plenty of tests in the akka code base that does that. There is also community maintained in-mem journal for testing. See http://akka.io/community/ /Patrik fre 15 apr. 2016 kl. 23:16 skrev Spencer J

Re: [akka-user] In Akka how does cassandra react when it is full and cannot persist more messages

2016-04-15 Thread Patrik Nordwall
Akka does not automatically remove events. Event sourced systems normally keep all history, because it is important. Perhaps read up on some of the concepts. E.g. http://www.lagomframework.com/documentation/1.0.x/ES_CQRS.html /Patrik fre 8 apr. 2016 kl. 18:24 skrev Amruta : > In Akka we are usin

Re: [akka-user] Akka remote custom transport

2016-04-15 Thread Patrik Nordwall
I think replacing the transport is not going to end well. I'd recommend that you use Redis or whatever that is supported on that platform directly. You can still use actors locally on each node. /Patrik tors 14 apr. 2016 kl. 23:39 skrev Christoph Grotz : > Hi, > > I want to form a better understa

Re: [akka-user] AKKA persistence with big loading issue

2016-04-15 Thread Patrik Nordwall
What kind of flow control are you using? If you produce faster than consumed you will quickly fill up memory and eventually be out of it. /Patrik tors 14 apr. 2016 kl. 22:40 skrev Yan Pei : > It's better after I change to use persistAsync() instead of persist(). > What risk we might have to use

[akka-user] ANNOUNCE: Akka 2.4.4 Released

2016-04-14 Thread Patrik Nordwall
ad the help of 18 committers – thank you! For the full stats see the announcement on the website <http://akka.io/news/2016/04/14/akka-2.4.4-released.html>. Happy hakking! -- Patrik Nordwall Akka Tech Lead Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM Twitter:

Re: [akka-user] Split Brain?

2016-04-12 Thread Patrik Nordwall
; group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-us

Re: [akka-user] Split Brain?

2016-04-11 Thread Patrik Nordwall
Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/

Re: [akka-user] Stream Testkit expectNextType ?

2016-04-11 Thread Patrik Nordwall
Thanks, Derek On Sun, Apr 10, 2016 at 2:02 PM, Derek Wyatt wrote: > Alright. I'll play around with these over the next few days and send you a > PR. > > On Fri, Apr 8, 2016 at 12:12 PM Patrik Nordwall > wrote: > >> Hi Derek, >> Sounds like a great a

Re: [akka-user] Re: Akka Persistence with Cassandra

2016-04-08 Thread Patrik Nordwall
ystem/cassandra-journal] Failed to connect to > Cassandra and initialize. It will be retried on demand. Caused by: line > 2:13 no viable alternative at input 'MATERIALIZED' ( [CREATE] > MATERIALIZED...)* > > Regards, > Rajesh > > On Tuesday, April 5, 2016 at 10:

Re: [akka-user] Dstributing data in akka cluster (guidance needed)

2016-04-08 Thread Patrik Nordwall
akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Akka Tech Lead Ligh

Re: [akka-user] Akka Streams Remote Materialization

2016-04-08 Thread Patrik Nordwall
.google.com/group/akka-user. >>>> For more options, visit https://groups.google.com/d/optout. >>>> >>> >>> >>> >>> -- >>> Akka Team >>> Typesafe - Reactive apps on the JVM >>> Blog: letitcrash.com >>&

Re: [akka-user] Akka persistence - errors on the read side

2016-04-08 Thread Patrik Nordwall
mSequenceNr parameter in the query traits. So the read >>> side would have to persist a watermark? Where? I was hoping for less >>> boilerplate. >>> >>> On Fri, Feb 26, 2016 at 5:47 AM, Patrik Nordwall < >>> patrik.nordw...@gmail.com> wrote: >>

Re: [akka-user] Stream Testkit expectNextType ?

2016-04-08 Thread Patrik Nordwall
> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from i

Re: [akka-user] Why should nodes usually not include themselves in seed node list?

2016-04-08 Thread Patrik Nordwall
email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Akka Tech Lead Lightbend &

Re: [akka-user] ANNOUNCE: Released akka-stream-kafka 0.11-M1

2016-04-08 Thread Patrik Nordwall
sage because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

2016-04-07 Thread Patrik Nordwall
Thanks :) tors 7 apr. 2016 kl. 17:26 skrev Viktor Klang : > https://github.com/akka/akka/issues/20256 > > On Thu, Apr 7, 2016 at 5:18 PM, Patrik Nordwall > wrote: > >> I agree, we have had that conclusion several times, but never fixed it. >> An issue is a good star

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

2016-04-07 Thread Patrik Nordwall
> On Thu, Apr 7, 2016 at 4:17 PM, Patrik Nordwall > wrote: > >> >> >> On Thu, Apr 7, 2016 at 12:46 PM, Viktor Klang >> wrote: >> >>> That is surprising, indeed. >>> What was the cause for that, again? >>> >> >> The ori

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

2016-04-07 Thread Patrik Nordwall
On Thu, Apr 7, 2016 at 12:46 PM, Viktor Klang wrote: > That is surprising, indeed. > What was the cause for that, again? > The original reason is for shutting down the dispatchers, I think. > > On Thu, Apr 7, 2016 at 12:39 PM, Patrik Nordwall < > patrik.nordw...@gmail

Re: [akka-user] Slf4j Akka adapter

2016-04-07 Thread Patrik Nordwall
kka.io> @ Lightbend <http://typesafe.com> > <http://lightbend.com> > > On 31 March 2016 at 09:13:36, Patrik Nordwall (patrik.nordw...@gmail.com) > wrote: > > Sounds interesting. I will take a look, but no time this week. > Regards, > Patrik > > On Fri, Mar 25, 201

Re: [akka-user] Akka streams on a cluster workaround : Is it acceptable approach?

2016-04-07 Thread Patrik Nordwall
You might find https://github.com/akka/reactive-kafka interesting /Patrik tors 7 apr. 2016 kl. 09:11 skrev JongHyok Lee : > Hello, > > I'm trying to make dynamic data stream processing engine which can > > - read data from multiple topics on multiple Kafka cluster > - apply several steps of da

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

2016-04-07 Thread Patrik Nordwall
One gotcha with shutting down the actor system is that scheduled tasks will run (immediately) when the scheduler is shutdown. /Patrik tors 7 apr. 2016 kl. 12:14 skrev Viktor Klang : > Or rather, if scheduled events are not cancelled hen they are no longer > needed, it will be a memory leak. Memo

Re: [akka-user] Re: Cloud Foundry + AKKA Cluster

2016-04-05 Thread Patrik Nordwall
51", >"akka.tcp://ClusterSystem@127.0.0.1:2552"] > > auto-down-unreachable-after = 10s >} > > If I deploy the Application with above configuration to different nodes, > will those nodes join the cluster automatically by identify themself as

Re: [akka-user] Re: Cloud Foundry + AKKA Cluster

2016-04-05 Thread Patrik Nordwall
I have heard that you can run Cassandra in CF. i think you would need a similar solution for Akka seed nodes as how Cassandra contact points are handled in CF. If someone has a better answer or knows how Cassandra in CF works I would also be curious to know. /Patrik tis 5 apr. 2016 kl. 18:12 skr

Re: [akka-user] Dispatcher for ClientResponseTunnel

2016-04-05 Thread Patrik Nordwall
m this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://group

Re: [akka-user] Re: Akka Persistence with Cassandra

2016-04-04 Thread Patrik Nordwall
Could it be something with authentication? tis 5 apr. 2016 kl. 05:41 skrev Madabhattula Rajesh Kumar < mrajaf...@gmail.com>: > > > On Monday, April 4, 2016 at 6:29:58 PM UTC+5:30, Madabhattula Rajesh Kumar > wrote: >> >> >> Hi, >> >> I am not able to connect Cassandra journal from Akka Persistenc

Re: [akka-user] [reactive-kafka 0.9.0.1] Why is my use of reactive-kafka so slow on commit?

2016-04-03 Thread Patrik Nordwall
The exception might be a bug. Please open an issue in https://github.com/akka/reactive-kafka You should use mapAsync for the commits. Otherwise you loose the backpressure. commit returns a Future. You don't need to use a graph for that simple flow, see the examples. /Patrik sön 3 apr. 2016 kl.

Re: [akka-user] Re: issue with receiveRecover and router

2016-04-02 Thread Patrik Nordwall
If you start two persistent actors they will recover independently of each other. That doesn't change because they are in a router pool. Probably you also used the same persistenceId for both instances and that is not allowed. Sounds good that you use a different design. /Patrik fre 1 apr. 2016

Re: [akka-user] Re: Dedicated seed nodes for akka cluster

2016-04-02 Thread Patrik Nordwall
If you use auto-downing and that triggers because of a network partition there will be two separate clusters and they will not recombine automatically. That's why we recommend against using auto-downing and instead recommend something like the Split Brain Resolver http://doc.akka.io/docs/akka/rp-16

Re: [akka-user] Re: Can't get akka clustering to work in docker

2016-04-02 Thread Patrik Nordwall
Thanks for sharing, Eric tis 22 mars 2016 kl. 19:16 skrev Eric Swenson : > Hi Endre, > > I have read that part of the documentation, and after switching to a new > cassandra journal keyspace, everything is working as it should be. I've > confirmed that if I bump the "ECS Service" count to 2 (or g

Re: [akka-user] Dead letters during hand-over of cluster singleton actors

2016-04-02 Thread Patrik Nordwall
It's hard to tell from that info what is going on. Can you provide a minimized sample that can be used to reproduce the issue? /Patrik tis 29 mars 2016 kl. 13:54 skrev : > I have a 2-node akka cluster. Whenever a deployment happens, I send a > akka-cluster (the JMX tool) "leave" command to each

Re: [akka-user] postStop doesn't get invoked after actor initialization failure

2016-04-02 Thread Patrik Nordwall
starting "b" because now "a" is started and >>>> it won't be stopped, >>>> >>>> >>>> I don't understand this question. If we failed starting "b" then it >>>> will not be running, thi

Re: [akka-user] [reactive-kafka 0.9.0.1] Why is my use of reactive-kafka so slow on commit?

2016-04-02 Thread Patrik Nordwall
There are examples in the readme to get you started. You should probably try batch commits. There are several examples of that (alternatives) in https://github.com/akka/reactive-kafka/blob/v0.11-M1/core/src/test/scala/examples/ConsumerExample.scala /Patrik lör 2 apr. 2016 kl. 00:35 skrev tigerfoo

Re: [akka-user] [reactive-kafka 0.9.0.1] Why is my use of reactive-kafka so slow on commit?

2016-04-01 Thread Patrik Nordwall
It would be interesting if you could try the new 0.11-M1. It's not ready for production yet, but we would like to measure and improve performance. https://github.com/akka/reactive-kafka /Patrik fre 1 apr. 2016 kl. 14:49 skrev Endre Varga : > Also, what version of streams is this? There is no reas

[akka-user] ANNOUNCE: Released akka-stream-kafka 0.11-M1

2016-04-01 Thread Patrik Nordwall
l guide you. For example: - add Java API - revive benchmarks - add more integration tests -- Patrik Nordwall Akka Tech Lead Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM Twitter: @patriknw [image: Lightbend] <http://www.lightbend.com/

Re: [akka-user] postStop doesn't get invoked after actor initialization failure

2016-03-31 Thread Patrik Nordwall
d, just > shuffling that code a bit around (famous last words?). > > On Thu, Mar 31, 2016 at 9:25 AM, Patrik Nordwall < > patrik.nordw...@gmail.com> wrote: > >> I think that is how it is implemented. Exception from preStart results in >> clearing the actor field and t

Re: [akka-user] postStop doesn't get invoked after actor initialization failure

2016-03-31 Thread Patrik Nordwall
FAQ: > http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" gr

Re: [akka-user] Slf4j Akka adapter

2016-03-31 Thread Patrik Nordwall
from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https:

Re: [akka-user] Can I use in-memory Actor state as a search engine ?

2016-03-30 Thread Patrik Nordwall
You may also want to take a look at Akka Distributed Data http://doc.akka.io/docs/akka/2.4.2/scala/distributed-data.html for replicating the search index (small enough amount of data I guess). /Patrik tors 31 mars 2016 kl. 04:35 skrev Chelios : > Hey Guido, > > Thanks heaps for this info. I only

Re: [akka-user] AKKA Persistence Cassandra is always always trying to connect 127.0.0.1 with cassandra-journal.contact-points setup

2016-03-30 Thread Patrik Nordwall
andra-journal' >> >> Regards, >> >> Emily >> >> On Tuesday, March 29, 2016 at 2:54:06 PM UTC-5, Patrik Nordwall wrote: >>> >>> Wrong config. Try >>> cassandra-journal.contact-points >>> without the akka.persistence

Re: [akka-user] AKKA Persistence Cassandra is always always trying to connect 127.0.0.1 with cassandra-journal.contact-points setup

2016-03-29 Thread Patrik Nordwall
Wrong config. Try cassandra-journal.contact-points without the akka.persistence prefix /Patrik tis 29 mars 2016 kl. 21:19 skrev Yan Pei : > Hello ALL, > >I am on my wits end to get this issue figured out by myself. Any > suggestion would be appreciated. > >The followings are information

Re: [akka-user] Remoting Load Balancing

2016-03-29 Thread Patrik Nordwall
Yes, it works and is still a very relevant pattern. /Patrik tis 29 mars 2016 kl. 18:15 skrev Fábio Melo : > This approach still works with currently version of akka? > > regards, > Fábio > > > On Thursday, August 9, 2012 at 7:01:05 AM UTC-3, rkuhn wrote: > >> You might want to read Derek’s new po

Re: [akka-user] akka://ClusterSystem/deadLetters

2016-03-28 Thread Patrik Nordwall
That is completely harmless. We should probably suppress the logging for that case. Please create an issue (and a pull request if you want to help out). /Patrik mån 28 mars 2016 kl. 18:53 skrev Viktor Klang : > ? > > -- > Cheers, > √ > On Mar 28, 2016 6:49 PM, "Sudha Vuppalapati" > wrote: > >> [

Re: [akka-user] Re: Node quarantined

2016-03-22 Thread Patrik Nordwall
We have fixed the issue that is noticed as "Error encountered while processing system message acknowledgement buffer: [-1 {}] ack: ACK[6, {}]" https://github.com/akka/akka/pull/20093 It will be released in 2.4.3 and 2.3.15, probably by end of next week. /Patrik tis 22 mars 2016 kl. 23:39 skrev G

Re: [akka-user] What is the impact of Kafka Streams on reactive-kafka?

2016-03-22 Thread Patrik Nordwall
-- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akk

Re: [akka-user] How-to restart a RunnableGraph on failure?

2016-03-21 Thread Patrik Nordwall
Could we have a termination Future, similar to the ActorSystem? mån 21 mars 2016 kl. 16:59 skrev Endre Varga : > Ah, OK that will work. The only issue is that shutdown() is asynchronous > so you cannot be fully sure when it has stopped everything. > > -Endre > > On Mon, Mar 21, 2016 at 4:58 PM, w

Re: [akka-user] Apparent thread leak with non-default akka dispatcher

2016-03-21 Thread Patrik Nordwall
for more information. > > cheers, > Jesse C > > > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: > http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>

Re: [akka-user] Akka remote communication roadmap?

2016-03-19 Thread Patrik Nordwall
e Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://group

Re: [akka-user] Akka remote communication roadmap?

2016-03-19 Thread Patrik Nordwall
ards the > final goal; if that was what you meant. > > Best regards, > > Guido. > > > > On Friday, March 18, 2016 at 9:47:00 AM UTC, Patrik Nordwall wrote: >> >> Hi all, >> >> A quick update of the roadmap for Akka Remoting. Lightbend's core A

Re: [akka-user] Re: Clarification on unreachable nodes in cluster

2016-03-19 Thread Patrik Nordwall
>>>>> become reachable again or marked as down >>>>>> >>>>>> Is this totally true? If a node is unreachable and is the >>>>>> leaving/exiting/removed state will this stop the leader from adding a new >>>>>>

Re: [akka-user] Akka remote communication roadmap?

2016-03-19 Thread Patrik Nordwall
d fit for actor messaging. > > The only scenario I see is the multicast, is it needed for akka-remoting? > > Cheers > > On 18 March 2016 at 09:46, Patrik Nordwall > wrote: > >> Hi all, >> >> A quick update of the roadmap for Akka Remoting. Lightbend's

Re: [akka-user] can sharding + ddata get out-of-sync ?

2016-03-15 Thread Patrik Nordwall
gt;>>>> Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email

Re: [akka-user] clustered singleton

2016-03-15 Thread Patrik Nordwall
googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Akka Tech Lead Lightbend <http://www.lightbend.com/>

Re: [akka-user] Querying Snapshot messages using Akka Persistence Query

2016-03-11 Thread Patrik Nordwall
uery, by > processing all events from the bottom of journal when there is a > possibility of significant reduction of this process both in time and > resources? > > W dniu piątek, 11 marca 2016 10:42:09 UTC+1 użytkownik Patrik Nordwall > napisał: >> >> >>

Re: [akka-user] awaitTermination not working?

2016-03-11 Thread Patrik Nordwall
t; > In other words, if I start a new node in the same test the function blocks > as expected. > > Thanks again. > > > On Fri, Mar 11, 2016 at 1:33 PM, Patrik Nordwall < > patrik.nordw...@gmail.com> wrote: > >> You must use shutdown followed by awaitTer

Re: [akka-user] awaitTermination not working?

2016-03-11 Thread Patrik Nordwall
l/faq.html > >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receivin

Re: [akka-user] Querying Snapshot messages using Akka Persistence Query

2016-03-11 Thread Patrik Nordwall
>>>>>>>>> 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/

Re: [akka-user] DistributedPubSub -- list of topics

2016-03-09 Thread Patrik Nordwall
> Visit this group at https://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> >> >> -- >> Akka Team >> Typesafe - Reactive apps on the JVM >> Blog: letitcrash.com >>

Re: [akka-user] Akka cluster: Passivation + reshard

2016-03-09 Thread Patrik Nordwall
because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit

Re: [akka-user] Problem with DistributedPubSub

2016-03-07 Thread Patrik Nordwall
s > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com

Re: [akka-user] change of Tech Lead

2016-03-07 Thread Patrik Nordwall
email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Akka Tech Lead Light

Re: [akka-user] Re: Problem with akka sharding 2.3.4

2016-03-07 Thread Patrik Nordwall
ceived this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@goog

Re: [akka-user] Design help: Akka clustering and dynamically created Actors

2016-02-26 Thread Patrik Nordwall
d email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM Twitter: @patriknw [image: Lightbend] <h

Re: [akka-user] Cluster aware router not getting any routees

2016-02-26 Thread Patrik Nordwall
ed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this

Re: [akka-user] Re: Scaling actors

2016-02-26 Thread Patrik Nordwall
; Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubs

Re: [akka-user] Akka persistence - errors on the read side

2016-02-26 Thread Patrik Nordwall
ka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Lightbend <http://www.light

Re: [akka-user] Re: Akka persistence with AtLeastOnceDelivery - Replay only unconfirmed messages

2016-02-26 Thread Patrik Nordwall
//groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To p

Re: [akka-user] Sharding: MessageExtractor receiving SaveSnapshotSuccess after enabling 'remember-entities'

2016-02-26 Thread Patrik Nordwall
ill discard the message do same with SaveSnapshotFailure > > -Morten > > On Fri, Feb 26, 2016 at 2:01 PM Patrik Nordwall > wrote: > >> That is a BUG. Please open an issue <https://github.com/akka/akka/issues>. >> It's rather easy to fix so if you are int

Re: [akka-user] Sharding: MessageExtractor receiving SaveSnapshotSuccess after enabling 'remember-entities'

2016-02-26 Thread Patrik Nordwall
are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://gr

Re: [akka-user] Re: akka persistence - silent failure for non serializing messages - is that the best we can do?

2016-02-26 Thread Patrik Nordwall
e test case - once I figured out > the problem) > Good, contributing to the TCK would be great. > > On 26 February 2016 at 12:29, Patrik Nordwall > wrote: > >> >> >> On Fri, Feb 26, 2016 at 12:47 PM, Tim Pigden >> wrote: >> >>> Hi - it'

Re: [akka-user] Akka: distributed pubsub. How to stop an unneeded publisher?

2016-02-26 Thread Patrik Nordwall
t; Blog: letitcrash.com > Twitter: @akkateam > > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: > http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>>>&

Re: [akka-user] Re: akka persistence - silent failure for non serializing messages - is that the best we can do?

2016-02-26 Thread Patrik Nordwall
ka User List" group. >>> To unsubscribe from this group and stop receiving emails from it, send >>> an email to akka-user+unsubscr...@googlegroups.com. >>> To post to this group, send email to akka-user@googlegroups.com. >>> Visit this group at https://groups.g

Re: [akka-user] Re: Actor System UIDs and Quarantine behaviour

2016-02-25 Thread Patrik Nordwall
mber 7098618) and its subsidiary undertakings (as > that expression is defined in the Companies Act 2006) from time to time. > The registered office of Ocado Group plc is Titan Court, 3 Bishops Square, > Hatfield Business Park, Hatfield, Herts. AL10 9NE. > > -- > >>>&

Re: [akka-user] Intended use for akka.Done and akka.NotUsed

2016-02-24 Thread Patrik Nordwall
>> -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: > http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>>>>>>> Search the archives: https://gr

Re: [akka-user] akka persistence - silent failure for non serializing messages - is that the best we can do?

2016-02-21 Thread Patrik Nordwall
e Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://

Re: [akka-user] How to detect sharding start failures and Singleon start failures?

2016-02-18 Thread Patrik Nordwall
re subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group

Re: [akka-user] Re: how to control lifetime of a sharded entity

2016-02-12 Thread Patrik Nordwall
oked that. > > Bert > > On Fri, Feb 12, 2016 at 12:14 PM, Patrik Nordwall < > patrik.nordw...@gmail.com> wrote: > >> I think it is documented that the entity id is the actor name. You are >> welcome to contribute with clarifications with a pull request if you like

Re: [akka-user] Re: how to control lifetime of a sharded entity

2016-02-12 Thread Patrik Nordwall
I think it is documented that the entity id is the actor name. You are welcome to contribute with clarifications with a pull request if you like. The entity type name should be well know by your application. A constant or you can pass it as a constructor parameter via the Props. No need to involve

Re: [akka-user] how to control lifetime of a sharded entity

2016-02-12 Thread Patrik Nordwall
>>>>>>>> Check the FAQ: > http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to th

Re: [akka-user] Re: Akka persistence query examples

2016-02-12 Thread Patrik Nordwall
oogle.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to

Re: [akka-user] Which of the data races are actually still happening in the current implementation of actors? can there be example code for each?

2016-02-11 Thread Patrik Nordwall
which is by itself a great > opportunity and will be of great value for Akka's users/developers. We are > working hard to publish some good results and helpful tools :), specific to > Akka but certainly applicable to similar distributed systems model(s). > > Best, > Mo &g

Re: [akka-user] Distributed Data for production use

2016-02-10 Thread Patrik Nordwall
It's mature and stable. You can use it in production. We use it in production in ConductR. We always use the experimental label for new modules to have the freedom to change API based on feedback before committing to binary backwards compatibility. The label will be removed in Akka 2.5, and we don

Re: [akka-user] Re: Akka Persistent Actor Lifecycle

2016-02-09 Thread Patrik Nordwall
You can use receive timeout (see actor section in documentation) and then stop it after inactivity. If you use Cluster Sharding you should combine that with the Passivate message as mentioned by Paul (see cluster sharding section in documentation). /Patrik tis 9 feb. 2016 kl. 16:01 skrev Paul Clear

Re: [akka-user] clustered singleton with supervised children

2016-02-08 Thread Patrik Nordwall
Y_CLUSTERED_SINGLETON/singleton/ITS_CHILD] >> >> On Monday, February 8, 2016 at 10:01:23 AM UTC-7, bitsof...@gmail.com >> wrote: >>> >>> Tried that, all i get from the proxy client side is this repeated over >>> and over >>> >>> >>> [Clus

Re: [akka-user] clustered singleton with supervised children

2016-02-07 Thread Patrik Nordwall
p receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > ​ --

Re: [akka-user] Akka 2.4.0-SNAPSHOT - a node can not complete joining the cluster?

2016-02-07 Thread Patrik Nordwall
Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email

Re: [akka-user] Get the ClusterStatus

2016-02-07 Thread Patrik Nordwall
roup and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout

Re: [akka-user] Target jvm 1.7 or no

2016-02-06 Thread Patrik Nordwall
Akka 2.4.x requires Java 8. You can use Akka 2.3.x with streams 2.0.x on Java 6/7 /Patrik lör 6 feb. 2016 kl. 22:19 skrev Mark van Buskirk : > Quick question, For akka 2.4.x will I be able to compile targeting jvm 1.7 > and run on a a 1.7 jvm or not. I'm using Scala and streams but deploying on >

Re: [akka-user] Akka 2.4.0-SNAPSHOT - a node can not complete joining the cluster?

2016-02-06 Thread Patrik Nordwall
Depends on when the snapshot was built. For example we found some snapshots on sonatype last week that were 6 months old. lör 6 feb. 2016 kl. 15:53 skrev Eugene Dzhurinsky : > I shut down the nodes couple of hours ago, but still can see that they are > in *Joining* state. > > Does 2.4.2-RC2 has so

Re: [akka-user] Akka 2.4.0-SNAPSHOT - a node can not complete joining the cluster?

2016-02-06 Thread Patrik Nordwall
Have you tried with 2.4.2-RC2? I think we have fixed something related to failure detection of joining node. /Patrik lör 6 feb. 2016 kl. 05:00 skrev Eugene Dzhurinsky : > Hello > > - I have a cluster with auto-join enabled > - the cluster consists of 10+ nodes > - sometimes a few (random !) nodes

Re: [akka-user] Re: Loading Actor State from DB and Failures

2016-02-05 Thread Patrik Nordwall
There has been updates to the BackoffSupervisor in 2.4.2-RC2, see api docs. fre 5 feb. 2016 kl. 21:35 skrev Paul Cleary : > Thanks a lot for all your help on this. I think I got this nailed. > > The BackoffSupervisor is sufficient, if not a little goofy to deal with. > > I am thinking that it wou

Re: [akka-user] Re: Akka 2.4+, Java 8 low latency micro-services JVM GC options

2016-02-05 Thread Patrik Nordwall
Thanks a lot for sharing, Guido! fre 5 feb. 2016 kl. 12:54 skrev Guido Medina : > Tests on Solr with JDK 8u72 corroborates my statement of G1GC looking good: > > https://wiki.apache.org/solr/ShawnHeisey > > > On Friday, February 5, 2016 at 11:50:16 AM UTC, Guido Medina wrote: >> >> It looks like f

Re: [akka-user] akka-persistence and serialization

2016-02-04 Thread Patrik Nordwall
message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. >

Re: [akka-user] Akka Cluster Flow Control

2016-02-04 Thread Patrik Nordwall
group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more optio

<    2   3   4   5   6   7   8   9   10   11   >