Re: [akka-user] Re: Akka Cluster ⇒ AssociationError Error [Invalid address]

Hi Eugene, I assume you've read the following but in case you didn't: http://doc.akka.io/docs/akka/2.3.12/scala/cluster-usage.html#Failure_Detector -- Cheers, √ On 18 Jul 2015 03:54, "Eugene Dzhurinsky" wrote: > I did some experiments, varying the number of nodes in the cluster, and > realize

[akka-user] Re: Akka Cluster ⇒ AssociationError Error [Invalid address]

I did some experiments, varying the number of nodes in the cluster, and realized that this error always happens with 6 nodes under the heavy load. It seems that if a single node can not communicate with another node in the cluster - that may lead to "unreachable" state, and then the node falls o

[akka-user] Re: Testing Akka Cluster in Maven

Unfortunately, I haven't found any way to do this in Maven. -- >> 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/akka-user ---

[akka-user] Re: Testing Akka Cluster in Maven

Were you able to do this? Can you provide some guidance on how to do it? On Sunday, May 4, 2014 at 9:32:49 AM UTC-7, Eugene Dzhurinsky wrote: > > Hello! > > I've read about the testing with *akka-multi-node-testkit*, however the > project I'm working on is based on Maven3. As far as I know, ther

Re: [akka-user] Creating Source from external service - Redis, SQS, etc...

The tweets example you mention here:  http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/scala/stream-integrations.html#Integrating_with_External_Services Relates to the quickstart – reactive tweets:  http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/scala/stream-quickstart.h

Re: [akka-user] Re: Akka persistence - replying to sender after multiple events persisted

Yep, that's how it works! :-) --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 17 July 2015 at 21:11:19, ahjohannessen (ahjohannes...@gmail.com) wrote: If that defer works as explained, then I can reduce my code to this: ... val durables = events map { e ⇒ DurableEvent(e, pid).causedBy(

Re: [akka-user] [akka-stream] Troubleshooting push-pull signal/token disappearance in a complex stream

Hi Jakub, most of the Akka team is on summer holidays, and it's now weekend… Would any of the awesome hAkkers on this ML be able to guide Jakub? s(I'm boarding a 9h flight as we speak). On Fri, Jul 17, 2015 at 5:21 PM, Jakub Liska wrote: > Hi, how are you guys tracking it? If your stream just

Re: [akka-user] Exceptions thrown by logger fn provided to FlowOps.log do not get handled by Resumer

Interesting. Please open an Issue. On Fri, Jul 17, 2015 at 8:31 PM, Tim Harper wrote: > I noticed this today: > > implicit val ec = ExecutionContext.global > case object LeException extends Exception("le fail") > implicit val materializer = > ActorMaterializer(ActorMateri

[akka-user] Re: Akka persistence - replying to sender after multiple events persisted

If that defer works as explained, then I can reduce my code to this: ... val durables = events map { e ⇒ DurableEvent(e, pid).causedBy(cm) } persist(durables)(applyEvent) defer()(_ ⇒ done) ... That's rather nice :) On Friday, July 17, 2015 at 8:04:54 PM UTC+1, ahjohannessen wrote: > > Andr

[akka-user] Re: Akka persistence - replying to sender after multiple events persisted

Andrew, I have also run into that and never paid much attention to defer, solved my problem in a rather clumsy way: private def processEvents(events: Seq[DomainEvent], cm: CommandMessage)(done: ⇒ Unit): Unit = { val durables = events map { e ⇒ DurableEvent(e, pid).causedBy(cm) } if(d

[akka-user] Re: Akka persistence - replying to sender after multiple events persisted

Ryan, I suppose that works because of: val d: ((Unit) ⇒ Unit) ⇒ Unit = defer() ? On Friday, July 17, 2015 at 4:00:43 PM UTC+1, Ryan Bair wrote: > > Hi Andrew, > > There is the defer method which handles this case rather nicely. > > case Message => > val events = ... > persist(events) > de

[akka-user] Exceptions thrown by logger fn provided to FlowOps.log do not get handled by Resumer

I noticed this today: implicit val ec = ExecutionContext.global case object LeException extends Exception("le fail") implicit val materializer = ActorMaterializer(ActorMaterializerSettings(actorSystem).withSupervisionStrategy(Supervision.resumingDecider : Supervision.Deci

[akka-user] [akka-cluster-sharding] When is the cluster ready?

Hi, When is the cluster ready to send messages to shard coordinators? Here my experience: The first time the application is running the code inside the Cluster(mainSystem).registerOnMemberUp callback block will run without any problem. The code just se

[akka-user] Akka Streams - How to define a Flow depending on the data coming from the Source? (AKA dinamically)

Hi all, this is my case: I have a queue (Rabbit MQ) producing Json data with the following format: { "id": 123, "message": "hello" } { "id": 876, "message": "shutdown" } { "id": 123, "message": "bye" } And I have a respective Consumer. What I want to do is to distribute the load depending on t

Re: [akka-user] [akka-streams] Feedback on the design of Akka Streams

Shapes describe what you can connect to things，maybe use 'Connector' is more Accurate, just a suggest, if i miss something, please correct me! 在 2015年7月17日星期五 UTC+8上午5:48:26，Konrad Malawski写道： > > 1. what is the different between Module and Shape? >> > Modules are internal things. > Shapes are "p

Re: [akka-user] [akka-streams] Feedback on the design of Akka Streams

stream-composition.html is a excellent work, thanks! i read it carefully,learn more about Akka stream. maybe there is a small mistake "nestedFlow will inherit from nestedSource except", it should be "from nestedSink"? thanks again! 在 2015年7月17日星期五 UTC+8上午5:48:26，Konrad Malawski写道： > > 1. what is

[akka-user] [akka-stream] Troubleshooting push-pull signal/token disappearance in a complex stream

Hi, how are you guys tracking it? If your stream just starts hanging and you cannot reproduce it because it only occurs in a complex stream. I'm able to see a few hints thanks to "ActorMaterializerSettings#withDebugLogging(enable = true)" and Log stage that tells me what stream stages are hangi

[akka-user] Re: Akka persistence - replying to sender after multiple events persisted

Ah, thanks. I'd got confused and thought the defer behaviour was only relevant when using persistAsync. Need to read the manual properly next time, doh! On Friday, 17 July 2015 16:00:43 UTC+1, Ryan Bair wrote: > > Hi Andrew, > > There is the defer method which handles this case rather nicely. >

[akka-user] Re: Akka persistence - replying to sender after multiple events persisted

Hi Andrew, There is the defer method which handles this case rather nicely. case Message => val events = ... persist(events) defer() { _ => sender() ! Ack } // Not run until persist completes On Friday, July 17, 2015 at 10:47:01 AM UTC-4, Andrew Easter wrote: > > I've got a persistent act

[akka-user] Akka persistence - replying to sender after multiple events persisted

I've got a persistent actor that, on processing a command, generates multiple events. There is support for persisting multiple events in the API: def persist[A](events: immutable.Seq[A])(handler: A => Unit): Unit In my use case, after all the events have been persisted, I wish to send an comman

[akka-user] How to create 3 or more distributed systems in akka

I want to create a distributed system using 3 Remote System(akka functionality) in akka framework using scala but every time when message reaches to 3rd remote system it error me with Drop me

Re: [akka-user] akka-http/spray REST API documentation?

This is being discussed as issue: https://github.com/akka/akka/issues/16591 And some initial proof-of-concept repos are already appearing: - https://github.com/kodemaniak/akka-http-restdoc - https://github.com/devsprint/akka-http-swagger I don’t think they’re “done” yet, but as you can see

Re: [akka-user] Re: Newbie Questions About PersistentView and Populating Read Datastores

API wise it could help you migrate once query side is out I guess. The type of the stream is simply Source[Any, _] (can be done with T), so if the rest of your app depends on such then you could do it. Getting backpressure will require some gymnastics but should be doable (don't poll if no deman

Re: [akka-user] Re: Newbie Questions About PersistentView and Populating Read Datastores

Hi Konrad do you think that creating a "streams adapter" that exposes the current PersistentView as a stream and then switching to the new impl when it's stable would be a good idea? On Friday, 17 July 2015 10:52:28 UTC+2, Konrad Malawski wrote: > > Hi guys, > A few things to add to the discussi

Re: [akka-user] Re: Newbie Questions About PersistentView and Populating Read Datastores

Hi guys, A few things to add to the discussion here :-) Multiple journals are supported in Akka Persistence since 2.4-M1. https://github.com/akka/akka/issues/15587 In general 2.4 will include all the things that were missing in persistence in its experimental phase. > *Push model:*Akka Persisten

Re: [akka-user] akka cluster MemberUp not happening fast enough - Why?

This sounds rather weird – can you provide a bit more details how you are joining the nodes? Is is seed nodes? Can you share some logs from the process? Please enable debug logging and akka.remote.log-remote-akkalifecycle-event Thanks! On Mon, Jul 13, 2015 at 9:37 AM, Moiz Raja wrote: > Hi All,

Re: [akka-user] Akka HTTP (Scala) 1.0-RC[12]: Processor actor terminated abruptly

Ah, sorry it requires logger being set to debug mode too. Thanks ! -- >> 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/akka-u

Re: [akka-user] Akka HTTP (Scala) 1.0-RC[12]: Processor actor terminated abruptly

I tried this already, but it doesn't seem to have any effect on logging... -- >> 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/grou

[akka-user] Types not aligning when using FutureDirectives onSuccess

Hi I have a hard time figuring out why the types will not align when using future directives onSuccess method. There is a gist created here that contains the code: https://gist.github.com/magnusart/a3b9321d6e391889d59a I've mucked around but cannot get the types to completely match up. I eithe

Re: [akka-user] Re: Connecting over Https using Akka-Http client

That clarifies it. Thnx! On Thursday, July 16, 2015 at 5:18:33 PM UTC+2, Johannes Rudolph wrote: > > Hi Jeroen, > > On Thu, Jul 16, 2015 at 4:35 PM, Jeroen Rosenberg > > wrote: > >> def gunzip(bytes: Array[Byte]) = { > >> val output = new ByteArrayOutputStream() > >> FileUtils.copyAll(new