Re: [akka-user] Akka Cluster seed node problem

es in seed nodes and first one is always the > running node (rather weird) this may allow to start any number of nodes in > any order and always guarantee cluster is initialized. > Am I missing something here? > > Thanks, > Andre Piwoni > > On Sunday, June

Re: [akka-user] akka-persistance issue

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 http

Re: [akka-user] bi-directional pubsub

mediator is an ActorRef so you can use ask. Note that ask is in akka.pattern.Patterns.ask /Patrik mån 28 dec. 2015 kl. 11:59 skrev ash.ta : > hi, > > i'm looking for a solution for the following task: > > i have 2 types of actors. their instances can be deployed in a local >

Re: [akka-user] bi-directional pubsub

ens in case all nodes with > the addressee actor are removed? will i get a time out waiting for a > callback or some kind of exception will be immediately thrown? > > thanks again! > > p.s. i use java api, if it's important. > > On Mon, Dec 28, 2015, 15:53 Patrik Nordwall <p

Re: [akka-user] bi-directional pubsub

You can change the routing logic in configuration. You can't change it for each message. It's possible to set it programatically. Then you do it via DistributedPubSubSettings and have to create the DistributedPubSubMediator actor yourself instead of using the DistributedPubSub extension. I

Re: [akka-user] Re: Akka PersistenceQuery java example

; 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 Typesafe <http://typesa

Re: [akka-user] Re: Akka PersistenceQuery java example

ave the same persistentId? > > > lørdag 26. desember 2015 13.15.05 UTC+1 skrev Patrik Nordwall følgende: > >> Each PersistentActor instance has a unique persistenceId. A >> PersistentActor instance can persist different types of events. >> > On Fri, Dec 2

Re: [akka-user] Shut down an actor system in multi-jvm tests

It must be done from the first node, where the concuctor runs. See akka source of multi-jvm tests for inspiration. fre 25 dec. 2015 kl. 18:08 skrev : > Hi hAkkers, > > I've been trying to figure out how to gracefully shutdown an actor system > (or a jvm) in multi-jvm

Re: [akka-user] Quarantined?

is 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@googlegrou

Re: [akka-user] Re: Deserialize ActorRef, again

t; } > > and > > serializers { >myown = "com.romix.akka.serialization.kryo.KryoSerializer" > } > > serialization-bindings { >"java.io.Serializable" = myown > } > > On Saturday, December 19, 2015 at 11:12:57 AM UTC-6, Patrik Nordwall

Re: [akka-user] Re: Akka PersistenceQuery java example

> 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 Typesafe <http://typ

Re: [akka-user] Re: Deserialize ActorRef, again

? > > On Friday, December 25, 2015 at 2:18:41 AM UTC-6, Patrik Nordwall wrote: > >> That should be the same thing, if there is only one binding to "java". >> > tors 24 dec. 2015 kl. 17:19 skrev <alex.f@gmail.com>: &g

Re: [akka-user] Re: Akka PersistenceQuery java example

er+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 Typesafe <http://typesafe.com/> -

Re: [akka-user] [Cluster singleton] Trying to identify singleton

;>>>>>>>>> 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

Re: [akka-user] Re: Deserialize ActorRef, again

Yeah, that is what I mean :-) lör 19 dec. 2015 kl. 18:09 skrev Guido Medina <oxyg...@gmail.com>: > Hey Patrik, to confirm; out of the 6 I listed only leave "java" as I had > it initially? > > > On Saturday, December 19, 2015 at 4:24:15 PM UTC, Patrik Nordwall wr

Re: [akka-user] [Cluster singleton] Trying to identify singleton

; 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 o

Re: [akka-user] Re: Deserialize ActorRef, again

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://grou

Re: [akka-user] Is it safe to call the deleteMessages method of a persistent actor with the current processed sequence number?

le 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/g

Re: [akka-user] Re: Feedback on BackoffSupervisor

ective on a normal supervisor, or by using the > `Restart` directive under the `TransparentExponentialBackoffSupervisor`. > Otherwise if left unhandled this exception will bubble all the way up to > the root guardian and cause the ActorSystem to shutdown." > > > On Thursday, December 17, 2015 at 3:18:47

Re: [akka-user] Re: Feedback on BackoffSupervisor

339) > at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > [success] Total time: 4 s, completed Dec 17, 2015 1:09:51 PM > > > > On Thursday, December 17, 20

Re: [akka-user] Re: Feedback on BackoffSupervisor

on to indicate failure?... > > "Location transparency, anyone?" ;-) > > Cheers, > Ray > > > > > > Cheers, > Ray > > On Wednesday, December 16, 2015 at 9:30:43 PM UTC+2, Raymond Roestenburg > wrote: >> >> Ok, I'll put a PR in for this. &g

Re: [akka-user] Gracefully downing Akka cluster shards

I don't understand. You have used the same entity type name when you started it. ClusterSharding(system).start ons 16 dec. 2015 kl. 21:41 skrev Carl Pulley : > Hi Patrik, > thanks for the reply. > > > I think that is included in the documentation: >>

Re: [akka-user] Gracefully downing Akka cluster shards

st" 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

Re: [akka-user] Re: Feedback on BackoffSupervisor

use 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. > V

Re: [akka-user] Gracefully downing Akka cluster shards

That's right. You're welcome ons 16 dec. 2015 kl. 22:27 skrev Carl Pulley : > Hi Patrik, > ah, I think the penny has just dropped!? > > > I don't understand. You have used the same entity type name when you >> started it. >> >> ClusterSharding(system).start > > > So

Re: [akka-user] Correct way to ask remote actor in consistent Hash router aware cluster

; --- > 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, sen

Re: [akka-user] Akka cluster sharding topology aware

>>>>>>>>>> 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 em

Re: [akka-user] akka.persistence, snapshots and deleting messages from journal

ribe 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 http://groups.google.com/group/akka-user. > For more options, visit https://

Re: [akka-user] at least once 'destination' to a distributed actor

/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 this g

Re: [akka-user] ClusterSingletonManager singleton actors not failing over (2 node cluster)

Thanks for updating. /Patrik tors 3 dec. 2015 kl. 16:16 skrev Alex Piggott <apigg...@ikanow.com>: > Thanks! Moving to 2.4.1 fixed the problem > > Alex > > > On Tuesday, December 1, 2015 at 1:45:54 PM UTC-5, Patrik Nordwall wrote: > >> Have you tried a stable ve

Re: [akka-user] Re: Microkernel Documentation is not on website

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@googlegroups.

Re: [akka-user] Akka-Persistence deleteMessages not deleting messages?

results here. Thanks a lot Patrik > > On Tue, Dec 1, 2015 at 10:41 AM, Patrik Nordwall < > patrik.nordw...@gmail.com> wrote: > >> Leveldb doesn't delete immediately. It will be done by a delayed >> (sometimes long) compaction process. >> /Patrik &g

Re: [akka-user] Akka-Persistence deleteMessages not deleting messages?

Leveldb doesn't delete immediately. It will be done by a delayed (sometimes long) compaction process. /Patrik sön 29 nov. 2015 kl. 16:10 skrev Harit Himanshu < harit.subscripti...@gmail.com>: > Hello there > > This is interesting as I was learning about snapshotting and deleting > messages in

Re: [akka-user] ClusterSingletonManager singleton actors not failing over (2 node cluster)

Have you tried a stable version? Latest is 2.4.1 /Patrik ons 25 nov. 2015 kl. 17:02 skrev Alex Piggott : > > I couldn't find anything like this on the mailing list or github > > I have a 2 node cluster running 2.4-M1 (scala 2.11). I use several > singleton actors (their code

Re: [akka-user] Delaying recovery?

Good catch. That requires some more thought. Please create an issue <https://github.com/akka/akka/issues/new>. Thanks, Patrik On Wed, Nov 25, 2015 at 1:27 PM, Brice Figureau <brice...@daysofwonder.com> wrote: > On Mon, 2015-11-16 at 14:57 +0100, Patrik Nordwall wrote: >

Re: [akka-user] Re: Akka DistributedPubSub ack

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@goog

Re: [akka-user] run time change in dispatchers

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 http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall

Re: [akka-user] Re: microservices multi actor persistence and sharding question.

gt;>> >>> How do I resolve this issue? I need persistence for my received events. >>> What is recommended paradigms in akka for this scenario. I am relatively >>> new to the akka world, please let me know if my understanding is incorrect >>> on akka cluster shar

Re: [akka-user] Re: Cluster aware consistent hashing pool - works only on leader

On Fri, Nov 20, 2015 at 8:46 AM, Jim Hazen <jimhazen2...@gmail.com> wrote: > > > On Thursday, November 19, 2015 at 12:32:38 PM UTC-8, Patrik Nordwall wrote: >> >> >> >> On Thu, Nov 19, 2015 at 8:06 PM, Jim Hazen <jimhaz...@gmail.com> wrote: &g

Re: [akka-user] Merge matching elements of multiple streams into Tuples

e 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 gr

Re: [akka-user] Re: Distributed version of Akka streams

>>>>>>>>>> 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

Re: [akka-user] [akka-stream] Is there any way I can do "conditional" Balance

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 http://groups.google.com/group/akka-user. > For

Re: [akka-user] DistributedPubSub - topic actor liveness race condition

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 this group, send em

Re: [akka-user] DistributedPubSub - topic actor liveness race condition

is call;" > > W dniu piątek, 20 listopada 2015 13:48:37 UTC+1 użytkownik Patrik Nordwall > napisał: >> >> The topic actors don’t stop themselves immediately. For efficiency >> reasons they stay around for a while even when there is no subscribers. See >> pru

Re: [akka-user] Re: Cluster aware consistent hashing pool - works only on leader

/TokenOAuthState#-1679280759] -> > Vector(35, -58, -66, 33), > Actor[akka://User/user/sharding/TokenOAuthState#-1778736418] -> Vector(-63, > 23, 50), Actor[akka.tcp:// > User@172.31.13.56:8115/user/sharding/TokenOAuthState#1939420601] -> > Vector(-23, 40, -11)),Set()) > > O

Re: [akka-user] Akka typed eventsourcing implementation template

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 http://groups.google.com/group/akka-user. &g

Re: [akka-user] Re: CPU-usage and a lot of actors with cluster-systems

What kind of work is performed by the actors? If you already have 2 actors I don't think the advice about delegating to futures will help. /Patrik ons 18 nov. 2015 kl. 20:36 skrev : > Be sure you aren't just separating your actors onto their own collective >

Re: [akka-user] Re: Cluster aware consistent hashing pool - works only on leader

Leveldb can't be used for cluster sharding, since that is a local journal. The documentation of persistence has links to distributed journals. An alternative is to use the ddata mode for cluster sharding, then Distributed Data will be used instead of Persistence for the internal state of Cluster

Re: [akka-user] Re: [akka-http] java completeWith mapping future

;>> Benoit >>> >>> -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: > http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>>>>>>> Searc

Re: [akka-user] [akka-stream] how to control the throughput of a certain flow

--- > 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 emai

Re: [akka-user] Akka cluster sharding exception propagation to the parent actor

persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111) > at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525) > at akka.actor.ActorCell.invoke(ActorCell.scala:494) > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257) > at akka.dispatch.Mail

Re: [akka-user] Re: Cluster Sharding - watching for termination of sharded actors.

; >>>>>>>>>> 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 fro

Re: [akka-user] Testing Streams - What's a Subscription?

om 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 http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com

Re: [akka-user] Supervision: Who just died

ribe 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 http://groups.google.com/group/akka-user. > For more options, visit https:

Re: [akka-user] What type of dispatcher to use when launching large number of Actors

; 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 http://groups.google.com/group/akka-user. > For

Re: [akka-user] Cluster Sharding Proxy vs Cluster Client

s 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 http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Types

Re: [akka-user] Supervision: Who just died

ck 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] ActorSelection vs ActorRef

You are right, Adam. I missed that the question was about restarts. /Patrik mån 16 nov. 2015 kl. 18:50 skrev Adam : > But that is not really accurate, isn't it? > > When restarted the ActorRef is still perfectly valid and you only need to > watch actors in case you have

Re: [akka-user] Re: Does akka 2.4 persistent actor cluster sharding Supervisor combination works on multi node cluster?

r we can use akka for production >> scenarios. Any help in clarifying the issue appreciated. >> >> >> Thanks, >> >> SD >> > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>

Re: [akka-user] Akka persistence query examples

an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Typesafe

Re: [akka-user] Sender reference for RandomPool in a cluster

cribe 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 http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.co

Re: [akka-user] ClusterSharding: Trigger Start of ShardCoordinator

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 http://groups.google.com/group/akka-user. > For more options, visit https://grou

Re: [akka-user] akka sharding monitoring

; 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..

Re: [akka-user] Re: persistentActor not receiving messages??

.(PersistentActorSpec.scala:25) at akka.persistence.PersistentActorSpec$Behavior1PersistentActor.(PersistentActorSpec.scala:45) ... 18 more ​ On Fri, Nov 6, 2015 at 4:16 PM, Ian Holsman <i...@holsman.com.au> wrote: > completely silent. > > > On Thu, Nov 5, 2015 at 11:58 P

Re: [akka-user] Re: [Akka-persistence 2.4] How to retry failed message

Regarding resume, if the persist fails the PA will unconditionally be stopped, so there is no supervision involved (no resume) for persist failures. What the BackoffSupervisor does is to start the PA again after exponential backoff delay. /Patrik tors 5 nov. 2015 kl. 18:11 skrev

Re: [akka-user] Re: [Akka-persistence 2.4] How to retry failed message

Messages that are already in the PA mailbox will be dropped (dead letters) when the actor is stopped. The BackoffSupervisor also drops messages during the backoff, and as discussed earlier some kind of resending is needed to make sure that all messages make it at-least-once. Read about the

Re: [akka-user] Re: persistentActor not receiving messages??

Didn't you see anything in the logs? I'm asking because if it is silent it is something we must improve. /Patrik fre 6 nov. 2015 kl. 01:28 skrev Ian Holsman : > Thanks Matheus. > That resolved the issue. > > Regards > Ian > > On Thu, Nov 5, 2015 at 6:17 PM,

Re: [akka-user] Efficient - transmit only once - broadcast?

onstantinos Kougios' via Akka User List" < > akka-user@googlegroups.com> wrote: > >> >> >> On 04/11/15 06:10, Patrik Nordwall wrote: >> >> Publishing to topic with Distributed PubSub will only transfer the >> message once per node that has

Re: [akka-user] Is the default leveldb production ready?

nded for testing. >> >> Eric >> >> On Wednesday, March 19, 2014 1:47:15 AM UTC-7, Patrik Nordwall wrote: >>> >>> >>> >>> >>> On Wed, Mar 19, 2014 at 5:00 AM, Eric Weise <ewe...@gmail.com> wrote: >>> >>

Re: [akka-user] Efficient - transmit only once - broadcast?

Publishing to topic with Distributed PubSub will only transfer the message once per node that has any subscribers. However, how large is large? Akka remoting is not designed for large messages, so you should consider splitting it up in parts or use another side channel, such as http or Akka IO.

Re: [akka-user] [Akka Cluster 2.4] Blog post about Shard Rebalancing, Remember Entities and Graceful Shutdown

Great blog post, Gabriel! Thanks for sharing. /Patrik mån 2 nov. 2015 kl. 10:47 skrev Gabriel Volpe : > I wrote a post after the work I've been doing to share what I learned. > > https://partialflow.wordpress.com/2015/11/02/akka-cluster-2-4/ > > Cheers, > Gabriel. > > --

Re: [akka-user] akka-http, websockets, and cluster sharding

This is the interesting log entry: ClusterSystem-akka.remote.default-remote-dispatcher-6] [akka.cluster.ClusterActorRefProvider] Error while resolving address [akka://HttpSystem] due to [No transport is loaded for protocol: [akka], available protocols: [akka.tcp]] Looks like you have one

Re: [akka-user] Cluster sharding with Persistence: Failing require statement,

lel run. I hope that fixes the issue and allows to >> recover to a state before the data was corrupted. >> >> On Tuesday, June 30, 2015 at 4:25:56 AM UTC-7, Patrik Nordwall wrote: >>> >>> What version of Akka are you using? >>> Can you run it wit

Re: [akka-user] Re: [Akka Cluster 2.4] Rebalancing and Remember entities

>>> 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 the Google Groups > &quo

Re: [akka-user] Re: Akka-Spray application losing messages

%% "akka-slf4j" >> % "2.3.6", >> "com.typesafe.akka" %% "akka-testkit" >> % "2.3.6" % "test" >> >> - Two actors: Producers and Consumers >> >> -- Send

Re: [akka-user] What does it means : notifying others about successful state changes by publishing events ?

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 http://groups.google.com/group/akka-user. > For more options, visi

Re: [akka-user] Re: How to get the count of messages from stream?

e actor. You can fan-out for parallel processing, see http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/scala/stream-parallelism.html#Parallel_processing > > Em sexta-feira, 23 de outubro de 2015 12:47:56 UTC-3, Patrik Nordwall > escreveu: > >> >> >> On Fri,

Re: [akka-user] Re: How to get the count of messages from stream?

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 the Google Groups > "Akka User List" group. &

Re: [akka-user] Re: How to get the count of messages from stream?

nsists of many stages that are quick, since it reduces the overhead of the asynchronous boundaries. It will be possible to demarcate which parts of a flow/graph that should not be fused. /Patrik > > Thanks, > Jeeva > > On Friday, October 23, 2015 at 3:48:06 PM UTC+5:30, Patrik Nordwall

Re: [akka-user] Re: Spray 1.3.3 and Aka 2.4

That is music to my ears. Thanks for confirming. /Patrik tors 22 okt. 2015 kl. 19:45 skrev Mike Mckibben : > I have a Spray 1.3.3 application and recently migrated to akka 2.4 with no > issues. > > > On Wednesday, October 21, 2015 at 3:19:23 PM UTC-6, rrodseth wrote: >>

Re: [akka-user] How to survive recovery failure?

akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Typesafe <http://typesaf

Re: [akka-user] difference between dispatcher and route?

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 http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optou

Re: [akka-user] Shared cluster shard allocation strategy

at would be very helpful! > > Thanks, > Vikas > > On Saturday, November 22, 2014 at 8:08:04 AM UTC-8, Patrik Nordwall wrote: >> >> Hi Moritz, >> >> On Wed, Nov 19, 2014 at 3:27 PM, Moritz Schallaböck < >> moritz.sc...@agido.com> wrote: >> >>&g

Re: [akka-user] Combine FSM[S, D] and DiagnosticActorLogging

bscribe 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 http://groups.google.com/group/akka-user. > For more options, visit https://groups.goog

Re: [akka-user] Messages being loss on an Akka Cluster

t;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 http://groups.google.com/group/akka-user. > For

Re: [akka-user] is akka.actor.ActorNotFound possible after context.actorOf(...)?

a/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" group. > To unsubscribe from this gro

Re: [akka-user] AllocationStrategy rebalance() is stopping actors outside resharding list

a charm. > > Many thanks for your help! > > > El lunes, 19 de octubre de 2015, 17:05:15 (UTC+2), Eduardo Fernandes > escribió: >> >> Ok. I'l work on that. >> >> Thanks. >> >> El lunes, 19 de octubre de 2015, 14:39:46 (UTC+2), Patrik Nordwall >

Re: [akka-user] Akka Cluster seed node config for restarts

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

Re: [akka-user] Event-sourcing with aka-persistence

done with all events. > > Dne pondělí 19. října 2015 12:15:33 UTC+2 Patrik Nordwall napsal(a): >> >> If I understand it correctly your question is about how to persist the >> LevelEarned event which comes via the >> asyncrounous player.observable.subscribe callback. Si

Re: [akka-user] Why is aroundReceive protected[akka]?

at'd be awesome! >> >> -- >> Cheers, >> Konrad 'ktoso’ Malawski >> Akka <http://akka.io> @ Typesafe <http://typesafe.com> >> >> On 21 October 2015 at 00:48:42, Justin du coeur (jduco...@gmail.com) >> wrote: >> >> On Mon, Oct 19, 2

Re: [akka-user] Why is aroundReceive protected[akka]?

There is also the Receive Pipeline http://doc.akka.io/docs/akka/2.4.0/contrib/receive-pipeline.html /Patrik mån 19 okt. 2015 kl. 00:33 skrev Konrad Malawski < konrad.malaw...@typesafe.com>: > Hi Jan! > > Yes, it's definitely one of those > > "Do not do this because you will most likely shoot

Re: [akka-user] AllocationStrategy rebalance() is stopping actors outside resharding list

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 htt

Re: [akka-user] Cluster sharding shutdown and restart in proxy mode

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@

Re: [akka-user] Event-sourcing with aka-persistence

>> 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-u

Re: [akka-user] Re: Websockets with Elasticsearch ScrollPublisher - Requesting more elements

tional/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 s

Re: [akka-user] address is now gated for [5000] ms

g 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 http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik

Re: [akka-user] Issues in AKKA persistence w/ KAFKA

e 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...@g

Re: [akka-user] SharedLeveldbJournal questions

ubscribe 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 http://groups.google.com/group/akka-user. > For more options, visit https

Re: [akka-user] address is now gated for [5000] ms

System.currentTimeMillis - startprintln(s"done waiting cluster, > waited $dt ms") > > > Normally this takes 1-2 seconds. But when the gate issue occurs, it takes > a lot more, i.e. 10 secs as per above. > > Cheers > > > On 19/10/15 10:50, Patrik Nordwall wr

Re: [akka-user] Sharding Coordinator updates its state incorrectly after rebalancing

> 1 (2551), which is down. This results in failures to deliver messages to > the actors that live in "c" ... "f". > Those are supposed to be removed by the watch in the coordinator, but I'm expecting them to be removed immediately since 2551 is no longer a cluster member. P

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