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

2015-07-18 Thread Tim Harper
Done. https://github.com/akka/akka/issues/18037 On Friday, July 17, 2015 at 2:32:36 PM UTC-6, √ wrote: > > 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

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

2015-07-18 Thread Eugene Dzhurinsky
Yes, I've read that, and I think that I *may* face some network issues now. I decreased the number of actors for each node to 5 with roundrobin pool, and that seems to solve the problems - for the last night there's no issue with the node marked as failed. The cluster is deployed on 7 nodes (3

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

2015-07-18 Thread Giovanni Alberto Caporaletti
Hi, https://gist.github.com/TrustNoOne/c7087713fa78375b2cb0 is a small POC I did today to check if the PersistentViewSource idea worked. I added some docs since I decided to post it but it has not been tested (well, I actually ran it like 10 times total lol). I'm not sure but there was somethi

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

2015-07-18 Thread Konrad Malawski
Of course, I'd like to help. Are these docs stored in the akka/akka github repo? Awesome, thanks in advance! The sources are on the release-2.3-dev branch (for all akka streams things): https://github.com/akka/akka/blob/release-2.3-dev/akka-docs-dev/rst/scala/stream-quickstart.rst https://github

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

2015-07-18 Thread Alexander Zafirov
Hi Konrad, Thanks for the reply! You're right that we should explain what it is on the integrations page > (would you like to submit a PR to help us with that? a :ref: link to the > quickstart would help I think). > Of course, I'd like to help. Are these docs stored in the akka/akka github re