Re: [akka-user] Akka Sharder Buffer Messages for UnReachable node

2017-02-07 Thread Patrik Nordwall
uot; 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. > Fo

Re: [akka-user] java.lang.VerifyError after shading with sbt-assembly

2017-02-07 Thread Patrik Nordwall
gt;>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/c >>> urrent/additional/faq.html >>> >>>>>>>>>> Search the archives: https://groups.google.com/grou >>> p/akka-user >>> --- >>>

Re: [akka-user] Help: how to persist different actor types in different shard regions?

2017-02-07 Thread Patrik Nordwall
ibed 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

Re: [akka-user] Graceful method to shutdown akka cluster

2017-02-04 Thread Patrik Nordwall
You mean rolling upgrade? Stop a few nodes add new nodes, stop some more, and so on? It's possible with Cluster.leave and such in Akka 2.4 but we have done major improvements in this area for upcoming 2.5. You can try 2.5-M1. http://doc.akka.io/docs/akka/2.5-M1/scala/actors.html#Coordinated_Shutdo

Re: [akka-user] Snapshot and Journal Cleanup

2017-02-02 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] Is there a standard way of referencing external objects inside of custom serializers?

2017-02-02 Thread Patrik Nordwall
es: https://groups.google.com/grou >>>>>>>>>>> p/akka-user >>>>>>>>>>> >>>>>>>>>> --- You received this message because you are subscribed to the > Google Groups "Akka User List" group. > To unsubscrib

Re: [akka-user] CRDT gossip implementation - replication flow

2017-02-02 Thread Patrik Nordwall
Hopefully we can have a release candidate of 2.5.0 out within a month. The more people that help out with the remaining tasks the quicker we can get it done. See issues on github milestone 2.5.0. We can also release another milestone if needed. /Patrik tors 2 feb. 2017 kl. 06:07 skrev Vadim Punski

Re: [akka-user] CRDT gossip implementation - replication flow

2017-01-31 Thread Patrik Nordwall
On Tue, Jan 31, 2017 at 7:26 AM, Vadim Punski wrote: > > > On Tuesday, January 31, 2017 at 4:02:51 PM UTC+2, Patrik Nordwall wrote: >> >> >> >> On Tue, Jan 31, 2017 at 6:42 AM, Vadim Punski wrote: >> >>> >>> >>> On M

Re: [akka-user] CRDT gossip implementation - replication flow

2017-01-31 Thread Patrik Nordwall
On Tue, Jan 31, 2017 at 6:42 AM, Vadim Punski wrote: > > > On Monday, January 30, 2017 at 4:29:13 PM UTC+2, Patrik Nordwall wrote: >> >> >> It's sent to one random node per tick, not all nodes. >> > > Node per tick, you're right ... > > >

Re: [akka-user] CRDT gossip implementation - replication flow

2017-01-30 Thread Patrik Nordwall
arch 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+unsubscr...@googlegr

Re: [akka-user] Saving snapshots

2017-01-26 Thread Patrik Nordwall
kka/akka/issues/22233 > > On Thu, Jan 26, 2017 at 7:25 AM, Patrik Nordwall < > patrik.nordw...@gmail.com> wrote: > > There is already a counter (the sequence number) that you can use. > > if (lastSequenceNr % snapShotInterval == 0 && lastSequenceNr != 0) >

Re: [akka-user] Saving snapshots

2017-01-26 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 > emai

Re: [akka-user] Re: I'm a freshman to Akka, please recommend me some useful learning material... Thanks a lot.

2017-01-26 Thread Patrik Nordwall
.google.com/group/akka-user. >>>> For more options, visit https://groups.google.com/d/optout. >>>> >>>> -- >>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>> >>>>>>>>>> Check the FAQ:

Re: [akka-user] Shard coordinator issue

2017-01-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 group at htt

Re: [akka-user] How to stop ReliableDeliverySupervisor log?

2017-01-26 Thread Patrik Nordwall
failed, address is now gated for [5000] ms. Reason: [Association failed > with [akka.tcp://system@0.0.0.0:1]] Caused by: [Connection refused: / > 0.0.0.0:1] > 11:24:17.094 [system-akka.actor.default-dispatcher-3] WARN > akka.remote.ReliableDeliverySupervisor > - Asso

Re: [akka-user] how to stop waiting for association failed remote??

2017-01-26 Thread Patrik Nordwall
/system@0.0.0.0:1] has > failed, address is now gated for [5000] ms. Reason: [Association failed > with [akka.tcp://system@0.0.0.0:1]] Caused by: [Connection refused: / > 0.0.0.0:1] > > 11:21:23.102 [system-akka.actor.default-dispatcher-4] WARN > akka.remote.Reliab

[akka-user] ANNOUNCE: Akka 2.5-M1

2017-01-26 Thread Patrik Nordwall
ject/migration-guide-2.4.x-2.5.x.html#Persistence_Query> section in the migration guide. Credits The complete list of closed tickets can be found on the 2.5-M1 <https://github.com/akka/akka/milestone/32?closed=1> milestones on github. For this release we had the help of 26 committers – t

Re: [akka-user] Exception when AKKA cluster haven't setup

2017-01-19 Thread Patrik Nordwall
ug from eclipse >> >> On Tuesday, 17 January 2017 14:06:36 UTC+8, Patrik Nordwall wrote: >>> >>> Akka version? >>> >>>> >>>> -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>&g

Re: [akka-user] Akka Cassandra Persistence: multiple manifests?

2017-01-18 Thread Patrik Nordwall
/ > 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 th

Re: [akka-user] Re: Akka Persistent Actor stops processing messages

2017-01-18 Thread Patrik Nordwall
er the problem earlier, with less load, by slowing down the serializer or writes (adding a sleep there, or patching akka-persistence-cassandra with sleeps and extra logging)? > > Again thanks for any help, I'm currently in the process of building a > local version of Akka that I can in

Re: [akka-user] Re: Akka Persistent Actor stops processing messages

2017-01-17 Thread Patrik Nordwall
e is never >>> returning which is all I can think of at this time. I've now set a limit on >>> the internal stash but that will only prevent the OOM exception but my >>> actor will still stop processing data. >>> >>> Any pearls of wisdom are appr

Re: [akka-user] Persisting entirely in JSON

2017-01-16 Thread Patrik Nordwall
On Mon, Jan 16, 2017 at 11:57 PM, Alan Burlison wrote: > On 16/01/17 21:22, Patrik Nordwall wrote: > > You should not serialize PersistentRepr, unless you are using a key-value >> store that can only store one single value per key. >> > > It's a flat file so th

Re: [akka-user] Exception when AKKA cluster haven't setup

2017-01-16 Thread Patrik Nordwall
Akka version? tis 17 jan. 2017 kl. 02:53 skrev Dai Yinhua : > Hi, > > I was running a akka cluster, but when I start only one instance of the > akka application, then it will throw below exception repeatedly, can you > help to explain what is the issue and how to avoid it. > > [ERROR] [01/17/2017

Re: [akka-user] Persisting entirely in JSON

2017-01-16 Thread Patrik Nordwall
You should not serialize PersistentRepr, unless you are using a key-value store that can only store one single value per key. Instead, grab the meta data fields from PersistentRepr and save them in separate columns. Grab the payload, serialize it, and save its bytes (the json) in a separate column.

Re: [akka-user] Akka router

2017-01-14 Thread Patrik Nordwall
Hard to say what is wrong based on that info, but the target actor is stopped. Perhaps it didn't start successfully (exc from constructor or preStart)? /Patrik PS. How old is 2.2.3? lör 14 jan. 2017 kl. 13:38 skrev Greg Karlin : > I am receiving the following exception: exception occurred > akka

Re: [akka-user] Dispatcher Problem

2017-01-14 Thread Patrik Nordwall
The host:port is not included in such address strings if it's the address of current local ActorSystem. The message is sent from 4001 and arrives at 4000 but when dispatching it to actor /user/speaker there is no actor running at that path. Perhaps you didn't start it or it has been stopped? /Patr

Re: [akka-user] akka-streams pattern for async filter

2017-01-13 Thread Patrik Nordwall
mapAsync.mapConcat with Future[Option] /Patrik fre 13 jan. 2017 kl. 23:44 skrev jdenizac via Akka User List < akka-user@googlegroups.com>: > Hi! I'm somewhat new to akka-streams and trying to find the best way to > express this flow: > > Let's say I have a stream of messages of type M for > > ca

Re: [akka-user] IllegalArgumentException during ShardCoordinator failover

2017-01-13 Thread Patrik Nordwall
up/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 th

Re: [akka-user] Akka Persistence - Seeing unexpected high number of journal reads

2017-01-12 Thread Patrik Nordwall
Your understanding is correct, it should not read after recovery. One reason could be that actors are restarted or stopped/started due to exceptions. /Patrik ons 11 jan. 2017 kl. 19:11 skrev Richard Ney : > My team is in pre-production and were chasing some odd behaviors that we > believe are con

Re: [akka-user] Akka persistent

2017-01-11 Thread Patrik Nordwall
hua] I have tried to set empty to > akka.cluster.sharding.snapshot-plugin-id, > and then shut down the node that shard coordinator running on, the fact is > that the shard coordinator could not recover on other node. > > > On Friday, 6 January 2017 19:38:10 UTC+8, Patrik

Re: [akka-user] Suggestions for cluster wide recipient list

2017-01-11 Thread Patrik Nordwall
earch 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+uns

Re: [akka-user] Cassandra journal startup in a clustered environment

2017-01-10 Thread Patrik Nordwall
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] Consistent Dissasociation, small cluster

2017-01-09 Thread Patrik Nordwall
e.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 thi

Re: [akka-user] Akka Artery

2017-01-07 Thread Patrik Nordwall
That is for the c++ client as far as I know, and that is not used by Akka. lör 7 jan. 2017 kl. 14:47 skrev Alan Burlison : > On 07/01/2017 12:54, Patrik Nordwall wrote: > > > In what environment have you seen that Aeron does not work? It works on > > Windows. It's Java, n

Re: [akka-user] Akka Artery

2017-01-07 Thread Patrik Nordwall
The Netty TCP based remoting is still supported, and is the default until Arterty has been battle tested. We will eventually phase out the old implementation, and we'll see if we need an alternative to Aeron. In what environment have you seen that Aeron does not work? It works on Windows. It's Jav

Re: [akka-user] Akka Artery

2017-01-06 Thread Patrik Nordwall
a-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 this gro

Re: [akka-user] Akka persistent

2017-01-06 Thread Patrik Nordwall
nse. > If it could, how does it work as it's not a distributed storage. > When it is started up on another node there will not be any snapshot to load since the file system is local, then it will replay all events instead. > > > On Thursday, 5 January 2017 22:09:23 UTC+8, Pat

Re: [akka-user] Example about cluster sharding

2017-01-05 Thread Patrik Nordwall
ad 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 > --- > You receiv

Re: [akka-user] Re: Akka cluster - on asymmetric failures

2017-01-05 Thread Patrik Nordwall
gt;> Francesco >>> >>> >> >> > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/ > current/additional/faq.html > >

Re: [akka-user] Akka persistent

2017-01-05 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 > em

Re: [akka-user] Akka clusters using cluster client causing quarantined nodes (v2.3.11)

2017-01-05 Thread Patrik Nordwall
>> [UniqueAddress(akka.tcp://appclustersys...@box1.company.com:12345 >> <http://appclustersys...@box1.company.com:12345>,-1669472141)]* >> *01/04/2017 06:44:45,355 INFO >> [AppClusterSystem-akka.actor.default-dispatcher-2] >> Cluster(akka://AppClusterSystem) - Cluste

Re: [akka-user] Consistent Dissasociation, small cluster

2017-01-05 Thread Patrik Nordwall
>>>> -XX:HeapDumpPath=$HOME/log/ \ >>>>>> -XX:+UseG1GC \ >>>>>> -XX:MaxGCPauseMillis=300 \ >>>>>> -XX:G1HeapWastePercent=20 \ >>>>>> -XX:InitiatingHeapOccupancyPercent=75 \ >>>>>> -XX:ConcGCThre

Re: [akka-user] Re: akka-cluster - generic failure detector configuration(S)

2017-01-03 Thread Patrik Nordwall
ponse from remote. Transport >> failure detector triggered. (internal state was Open) >> 16:47:23.109 [activity-feeds-akka.actor.default-dispatcher-6] INFO >> a.r.transport.ProtocolStateActor - No response from remote. Transport >> failure detector triggered. (internal sta

Re: [akka-user] Feasibility of multiple services sharing a single Akka cluster?

2017-01-03 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

Re: [akka-user] Unimplemented deserialization of message with manifest issue

2016-12-24 Thread Patrik Nordwall
This looks like a bug in the eventstore plugin that you are using. Please create an issue in its repository. It looks like it's not supporting SerializerWithStringManifest correctly. /Patrik lör 24 dec. 2016 kl. 09:00 skrev Hengky Sucanda : > Hi, > > I am running an application using Akka Persist

Re: [akka-user] Re: Using BackoffSupervisor with Shard Passivation

2016-12-22 Thread Patrik Nordwall
oogle 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

Re: [akka-user] Sharding Coordinator don't start from a youger node

2016-12-21 Thread Patrik Nordwall
t;test", >> entityProps = aggregateProps(aggregateId), >> settings = ClusterShardingSettings.create(actorSystem), >> extractEntityId = extractEntityId, >> extractShardId = extractShardId) >> >>val shard = ClusterSharding(actorSystem).s

Re: [akka-user] Sharding Coordinator don't start from a youger node

2016-12-20 Thread Patrik Nordwall
> [ClusterSystem-akka.actor.default-dispatcher-20] > [akka.tcp://ClusterSystem@172.19.0.3:2551/system/sharding/test] Trying to > register to coordinator at [Some(ActorSelection[Anchor(akka.tcp:// > ClusterSystem@172.19.0.2:2551/), Path(/system/sharding/ > testCoordinator/singleton/

Re: [akka-user] Sharding Coordinator don't start from a youger node

2016-12-20 Thread Patrik Nordwall
ator just startup when an actor is creating inside the node > .2(Oldest)? > > > > Thanks, > > > > Víctor > > El lunes, 19 de diciembre de 2016, 16:15:17 (UTC-5), Patrik Nordwall > escribió: > > Any errors in the log of 172.19.0.2:2551 > <http://www.google

[akka-user] ANNOUNCE: Akka 2.4.16

2016-12-20 Thread Patrik Nordwall
e list of closed issues can be found on the 2.4.16 <https://github.com/akka/akka/milestone/100?closed=1> milestones on github. For this release we had the help of 15 committers – thank you all very much! Credits: commits added removed 12 2597 402 Patrik Nordwall 11

Re: [akka-user] Sharding Coordinator don't start from a youger node

2016-12-19 Thread Patrik Nordwall
tal > [1] buffered messages. > > So, the prestart and the “cluster.subscribe(self, classOf[MemberEvent], > classOf[UnreachableMember])” are not execute. > > Do you have another idea? > > Thank you so much for your help, > > > > Victor > > > > El domingo,

Re: [akka-user] Understanding race conditions when creating actors

2016-12-18 Thread Patrik Nordwall
e 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] Newbie Question: akka cluster and auto rebalancing

2016-12-18 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

Re: [akka-user] Sharding Coordinator don't start from a youger node

2016-12-18 Thread Patrik Nordwall
# Default settings for the constant rate entity recovery strategy > > entity-recovery-constant-rate-strategy { > > # Sets the frequency at which a batch of entity actors is started. > > frequency = 100 ms > > # Sets the number of entity

Re: [akka-user] What's wrong with value classes as parameters?

2016-12-15 Thread Patrik Nordwall
Doesn't it work if you use the ordinary constructor: Props(new ValueActor(MyValue(10))) ? tors 15 dec. 2016 kl. 15:22 skrev Endre Varga : > On Thu, Dec 15, 2016 at 3:21 PM, Justin du coeur > wrote: > > Ahhh -- okay. The really key bit is further down in that section, under > "Value classes as c

Re: [akka-user] Re: Aeron errors when network temporarily disconnected.

2016-12-14 Thread Patrik Nordwall
Good that you found the reason. When using embedded media driver Akka will remove those files if you do a clean shutdown of the ActorSystem/jvm. If you would use an external media driver you would have to remove such files yourself. If you can create a small reproducer where files are not removed

Re: [akka-user] Re: How to force remove node from cluster?

2016-12-14 Thread Patrik Nordwall
You must Down all unreachable before they are removed. Same if you join. You must Down all unreachable before it is moved to Up. Restarting and joining again will trigger Down of previous incarnation with same host:port. Then you have to retry the join when the previous has been removed. Retries ar

Re: [akka-user] Aeron errors when network temporarily disconnected.

2016-12-14 Thread Patrik Nordwall
kka-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. >>

Re: [akka-user] Akka clusters using cluster client causing quarantined nodes (v2.3.11)

2016-12-10 Thread Patrik Nordwall
First step is to use latest version. Preferably 2.4.14, but if you are stuck on 2.3.x it is 2.3.15. Updating to 2.4.x should be fairly easy, see migration guide in docs. You need a version with this fix https://github.com/akka/akka/issues/13909 and there are many other bug fixes since 2.3.11 /Pat

[akka-user] ANNOUNCE: HTTP API for Akka Cluster management

2016-12-09 Thread Patrik Nordwall
management> and more contributions are welcome. -- Patrik Nordwall Akka Tech Lead Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM Twitter: @patriknw -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>&

Re: [akka-user] Re: akka-persistance - nested persist

2016-12-09 Thread Patrik Nordwall
ps.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] Play framework, Akka Persistence, PersistenceQuery, unable to convert Source to Future Object for Action.async

2016-12-05 Thread Patrik Nordwall
e 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] Play framework, Akka Persistence, PersistenceQuery, unable to convert Source to Future Object for Action.async

2016-12-04 Thread Patrik Nordwall
The original take(10) should also work if you have 10 or more events. mån 5 dec. 2016 kl. 03:58 skrev Justin du coeur : > Okay, good -- glad that helped... > > On Sun, Dec 4, 2016 at 8:51 PM, Srinivas wrote: > > Thanks Justin, > > Here is what I am doing > > class UserController extends Controlle

Re: [akka-user] akka networking for thousands of small messages

2016-12-03 Thread Patrik Nordwall
Akka User List < akka-user@googlegroups.com> wrote: > Hi Patrik, is that still the case (<1 ms) when 700k/sec msgs are send > between the actors? How many machines took part in the tests? > > On 02/12/16 21:05, Patrik Nordwall wrote: > > A few 100 microseconds is a

Re: [akka-user] akka networking for thousands of small messages

2016-12-02 Thread Patrik Nordwall
A few 100 microseconds is a reasonable expectation for delivery of a a message to a remote actor. /Patrik fre 2 dec. 2016 kl. 21:22 skrev 'Konstantinos Kougios' via Akka User List < akka-user@googlegroups.com>: > Hi Konrad, > > Thanks for the reply, thats good enough volume of messages :) > > Wha

Re: [akka-user] Unit test for Persistent Actor Replay

2016-12-02 Thread Patrik Nordwall
; definitionReader2 ! DefinitionReader.GetState > > On Fri, Dec 2, 2016 at 11:25 AM, Patrik Nordwall < > patrik.nordw...@gmail.com> wrote: > > For testing purposes you might need to optionally override that way of > defining the persistenceId by passing it in as construc

Re: [akka-user] Unit test for Persistent Actor Replay

2016-12-02 Thread Patrik Nordwall
Fri, Dec 2, 2016 at 10:59 AM, Richard Rodseth > wrote: > > I wondered about that, but the persistence id is derived from the name > (it's an aggregate root) > > override val persistenceId: String = "XYZ-" + self.path.name > > On Fri, Dec 2, 2016 at 10:53

Re: [akka-user] Unit test for Persistent Actor Replay

2016-12-02 Thread Patrik Nordwall
You can start the second actor with a different actor name but with the same persistenceId. If you don't specify the actor name a unique name will be used. /Patrik fre 2 dec. 2016 kl. 19:43 skrev Richard Rodseth : > I'm also looking here: > > https://github.com/akka/akka/blob/release-2.4/akka-pe

Re: [akka-user] Re: ClusterSingleton router location and routing logic

2016-11-30 Thread Patrik Nordwall
Distributed PubSub can be used as a dynamic router. /Patrik ons 30 nov. 2016 kl. 12:50 skrev Shyam : Thanks guys for the suggestions. Thinking to solve this by having some external logic which spawns the actors of a particular task on few nodes of the cluster, and register these actors with rou

Re: [akka-user] Is there a recommended max number of shard regions in a cluster?

2016-11-28 Thread Patrik Nordwall
n the name is as performant as my segmented actor regions > without the added complexity in deployment, management, and network > overhead? Maybe I was seeing a problem that doesn't really exist. > > On Saturday, November 26, 2016 at 8:23:12 AM UTC-8, Justin du coeur wrote:

Re: [akka-user] Re: Problem with clean shutdown using artery in cluster

2016-11-28 Thread Patrik Nordwall
ail 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 Ak

Re: [akka-user] Is there a recommended max number of shard regions in a cluster?

2016-11-26 Thread Patrik Nordwall
egions. > > Richard Ney > > > On Friday, November 25, 2016 at 8:25:02 AM UTC-8, Patrik Nordwall wrote: > > Let's see if I understand. You call ClusterSharding(system).start, with > unique typeName, dynamically when a new customer is created? > > On Sun, Nov 20, 201

Re: [akka-user] Akka EventBus - are terminated subscribers automatically unsubscribed?

2016-11-26 Thread Patrik Nordwall
Terminated actors are automatically unsubscribed from event bus. /Patrik tors 17 nov. 2016 kl. 09:17 skrev Jithin Thomas : > Hi all, > > I'm fairly new to Akka. So, please let me know if this question has been > answered elsewhere. > > I'm building a web server application using Scala Play and A

Re: [akka-user] Is there a recommended max number of shard regions in a cluster?

2016-11-25 Thread Patrik Nordwall
nsubscribe 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

Re: [akka-user] Node Roll Error with Distributed Data.

2016-11-25 Thread Patrik Nordwall
;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/group/a

Re: [akka-user] akka-kafka-stream "Offset Storage in Kafka" question/clarification

2016-11-24 Thread Patrik Nordwall
om what the offset that was stored in Kafka, i.e. it's at-least-once delivery > > Thanks, > Arun > > On Saturday, August 27, 2016 at 12:26:30 PM UTC+5:30, Patrik Nordwall > wrote: >> >> The commit commands are emitted to the underlying KafkaConsumer in right >&g

Re: [akka-user] remoting (classic version) without java serialization doesn't work?

2016-11-23 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

Re: [akka-user] Akka Agent for Scala 2.12

2016-11-21 Thread Patrik Nordwall
he sender is authorised to > state them to be the views of any such entity. > > The disclaimer forms part of the content of this e-mail in terms > of section 11 of the Electronic Communications and Transactions Act, 25 of > 2002. Refer to http://www.eoh.co.za/disclaimer > > O

Re: [akka-user] Non-monotonic incremental computation

2016-11-20 Thread Patrik Nordwall
Hi, delta-CRDTs are very interesting. Contribution to Akka Distributed Data would be much appreciated. Let me know if you have something I should review or if you want to discuss any design ideas. Probably best if you create an Akka github issue. /Patrik lör 19 nov. 2016 kl. 12:06 skrev Merlijn B

Re: [akka-user] Using "Distributed Data" for caching Tokens. Delete by value with LMWMap possible?

2016-11-18 Thread Patrik Nordwall
o 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://g

Re: [akka-user] Re: Akka cluster sharding messages default serialization

2016-11-18 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+unsubscr...@googlegr

Re: [akka-user] Is it a bug in deployment configuration?

2016-11-18 Thread Patrik Nordwall
t; 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-

Re: [akka-user] Timing of eventsByTag() and persist()

2016-11-17 Thread Patrik Nordwall
ser > --- > 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, se

Re: [akka-user] Re: Node rejoin seed node failure after seed node restart

2016-11-17 Thread Patrik Nordwall
ng 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. > -- Patrik Nord

Re: [akka-user] Re: Akka Agent for Scala 2.12

2016-11-14 Thread Patrik Nordwall
er > --- > 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

Re: [akka-user] Problem with nodes going down and ClusterSharding

2016-11-12 Thread Patrik Nordwall
What other downing strategy are you using? We recommend against auto-down. We recommend Split Brain Resolver or similar. No downing strategy at all is not an option. Then you must down manually (by human operator). /Patrik lör 12 nov. 2016 kl. 18:22 skrev kraythe : > Greetings, > > We have a clus

Re: [akka-user] Akka-remoting with Artery using load balancing/round robbing dns

2016-11-10 Thread Patrik Nordwall
And for the record, it's just accidental that it works with tcp. We don't guarantee that the same connection is reused. tors 10 nov. 2016 kl. 17:14 skrev Endre Varga : > Actor remote messaging is a P2P protocol and as such any kind of > name-remapping is harmful. Trying to load balance Akka Remote

Re: [akka-user] Need to publish with DistributedPubSubMediator when MemberUp in Cluster and Mediator is ready to publish to new node in cluster

2016-11-09 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-u

Re: [akka-user] Management tools for akka-cluster

2016-11-08 Thread Patrik Nordwall
> On Monday, November 7, 2016 at 6:13:38 PM UTC+1, Patrik Nordwall wrote: >> >> >> >> On Fri, Nov 4, 2016 at 11:53 AM, Javier Ferrer González < >> javier.m...@gmail.com> wrote: >> >>> Hi Patrik, >>> >>> 2 doubts: >>&

Re: [akka-user] [akka-persistence] readjournal query by multiple tags

2016-11-08 Thread Patrik Nordwall
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/> - Reactive apps on the JVM Twitter:

Re: [akka-user] Management tools for akka-cluster

2016-11-07 Thread Patrik Nordwall
ame host as one >> of the cluster nodes. > > > What kind of errors could I have working with the script on AWS? > I'm not sure what the problems were. Perhaps firewall issues. Note that there is a http based management api in the works: https://github.com/akka/akka-stream-contr

Re: [akka-user] Logging only from actors

2016-11-07 Thread Patrik Nordwall
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/> - Reactive apps on

Re: [akka-user] Re: New akka http for scala -- no server-side WebSocket docs? Can we have 2.4.11 docs back?

2016-11-01 Thread Patrik Nordwall
Old version: http://doc.akka.io/docs/akka/2.4.11/scala.html tis 1 nov. 2016 kl. 22:37 skrev : > Actually, I figured out how to get 2.4.11 and generate the documentation. > > > On Tuesday, November 1, 2016 at 1:37:00 PM UTC-4, mniel...@gmail.com > wrote: > > With Akka 2.4.12, the akka HTTP documen

Re: [akka-user] Akka-stream - source is not processed asynchronously?

2016-11-01 Thread Patrik Nordwall
ribed 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://groups.google.co

Re: [akka-user] Remote actor not reached if router invoked as soon as created ( messages goes to deadletters )

2016-11-01 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 >

Re: [akka-user] Can a cluster have multiple singleton actors?

2016-11-01 Thread Patrik Nordwall
uot; > } > } > > > cluster { > singleton { > singleton-name = "singleton2" > } > singleton-proxy { > singleton-name = *"*singleton2" > } > } > > > On Monday, October 31, 2016 at 9:31:45 AM UTC-6, Patrik Nordwall w

Re: [akka-user] How to reference an existing actor?

2016-11-01 Thread Patrik Nordwall
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 this group, send ema

Re: [akka-user] Actor systems in the cluster are quarantined too often

2016-10-31 Thread Patrik Nordwall
eceived 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@goo

Re: [akka-user] Can a cluster have multiple singleton actors?

2016-10-31 Thread Patrik Nordwall
scribed 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

Re: [akka-user] Some remote nodes not joining the cluster

2016-10-30 Thread Patrik Nordwall
nodes join the cluster. On Saturday, October 29, 2016 at 5:17:54 AM UTC-7, Patrik Nordwall wrote: Are you sure that there are no firewall rules or similar that are blocking between the nodes? /Patrik fre 28 okt. 2016 kl. 16:21 skrev Jegan : Hi Everyone, Apologies for a long post. I am using

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