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

I update more infomation > There is no rebalance for Shard [73] before it reallocated on node "akka.tcp://application@192.168.38.116:2770

[akka-user] Problem with akka sharding 2.3.4

Dear Akka Team! Actually I have an issue, that is when I restart the Akka Sharding in cluster with two nodes, the shard region in 2 nodes is not consistency I have some logs: 2016-03-04 15:06:48,231 - [DEBUG] - from akka.contrib.pattern.ShardRegion in application-akka.actor.default-dispatcher-2

[akka-user] Error while creating router from config

Hi, I am trying to create router from configuration but I'm getting ConfigurationException. My code is following: ActorRef subPathFinderRouter = context().actorOf(FromConfig.getInstance().props(Props.create(SubPathFinderActor.class)), "subPathFinderRouter"); Config: "/*/subPathFinderRoute

Aw: [akka-user] Usage of "nameLifted" in GraphDSL

A Source[Attributes] implemented by a custom GraphStage might be the solution. Is there something easier?   Gesendet: Freitag, 04. März 2016 um 17:22 Uhr Von: "Stefan Wachter" An: "Akka User List" Betreff: [akka-user] Usage of "nameLifted" in GraphDSL Hi all,   I have some processing logic

[akka-user] Usage of "nameLifted" in GraphDSL

Hi all,   I have some processing logic encoded in a flow F that is constructed using the GraphDSL (Scala version). The flow is included in a larger processing graph at multiple positions. Inside of F I need a unique identifier for every instantiation (i.e. materialization) because the various mat

[akka-user] Re: Using the Actor uid

*UID* = Unique Identifier just like: *UUID* = Universal Unique Identifier. On Friday, March 4, 2016 at 8:31:50 AM UTC, Tarisai Kunaka wrote: > > Hello > > I'd like to ask what exactly is an actor UID? > > >> -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ:

Re: [akka-user] Issue with Smallest Mailbox router pool introduced in akka 2.4.2

Okay, new ticket created: https://github.com/akka/akka/issues/19949 On Friday, March 4, 2016 at 7:46:55 AM UTC-5, √ wrote: > > I think: regression? > > On Fri, Mar 4, 2016 at 1:44 PM, Chris Baxter > wrote: > >> Should I create a separate ticket for this? It appeared to me like the >> issue wi

[akka-user] akka-http complete either directive with status code parameter

Hi, i' trying to build a custom directive which completes a *Future *of *Either*. However, the following only works if i omit the status code when completing the *Right* case (i.e. *complete(result)* ). def completeEither[A](successStatusCode: StatusCodes.Success, future: => Future[Either[Requ

Re: [akka-user] Issue with Smallest Mailbox router pool introduced in akka 2.4.2

I think: regression? On Fri, Mar 4, 2016 at 1:44 PM, Chris Baxter wrote: > Should I create a separate ticket for this? It appeared to me like the > issue with AbstractNodeQueue was fixed though. Am I reading this wrong? > > On Friday, March 4, 2016 at 7:38:47 AM UTC-5, √ wrote: >> >> Could be

Re: [akka-user] Issue with Smallest Mailbox router pool introduced in akka 2.4.2

Should I create a separate ticket for this? It appeared to me like the issue with AbstractNodeQueue was fixed though. Am I reading this wrong? On Friday, March 4, 2016 at 7:38:47 AM UTC-5, √ wrote: > > Could be related to: https://github.com/akka/akka/issues/19216 > > On Fri, Mar 4, 2016 at 1

Re: [akka-user] Issue with Smallest Mailbox router pool introduced in akka 2.4.2

Could be related to: https://github.com/akka/akka/issues/19216 On Fri, Mar 4, 2016 at 1:26 PM, Chris Baxter wrote: > I have noticed a strange issue after we upgraded to akka 2.4.2 that > appears sporadically but once it rears its ugly head it basically causes > the server to consume a ton of CPU

[akka-user] Issue with Smallest Mailbox router pool introduced in akka 2.4.2

I have noticed a strange issue after we upgraded to akka 2.4.2 that appears sporadically but once it rears its ugly head it basically causes the server to consume a ton of CPU and we have to restart. This issue appears to be with the smallest mailbox pool router. It gets hung up in peekNode in

Re: [akka-user] [akka-http-2.4.2] HttpConnectionTimeoutException logged at ERROR

Uh oh - I should have searched in the github issues :) Next time I will Thank you! G On Friday, 4 March 2016 10:30:30 UTC+1, Konrad Malawski wrote: > > Hi there, > it's not a bug, it's about shutting down connections when no data is > passed through it. > It's fixed already and will be part of t

Re: [akka-user] [akka-http-2.4.2] HttpConnectionTimeoutException logged at ERROR

Hi there, it's not a bug, it's about shutting down connections when no data is passed through it. It's fixed already and will be part of the 2.4.3 release:  https://github.com/akka/akka/pull/19915 Thanks for reporting! --  Cheers, Konrad 'ktoso’ Malawski Akka @ Lightbend On 4 March 2016 at 10:0

Re: [akka-user] Am I misunderstanding throttle?

Hi John, I had no time to look into your problem yet since I and the team is on a meeting this week. Please file a ticket and someone will pick it up next week. -Endre On Fri, Mar 4, 2016 at 6:49 AM, wrote: > Could this be a aka-streams bug? Should I open a git bug? > In-between I am using my

[akka-user] [akka-http-2.4.2] HttpConnectionTimeoutException logged at ERROR

[ERROR] [03/04/2016 08:31:12.592] [.dispatcher-145] [akka:///user/StreamSupervisor-1/-3347342-0-unknown-operation] Error in stage [recover]: No elements passed in the last 1 minute. (akka.http.impl.engine.HttpConnectionTimeoutException) I keep getting these, It would be ok if it was

[akka-user] Re: Connecting RabbitMQ with Java Actors

Hi TigerFoot, Thing is all these git projects are written in scala. And I also have the similar use case. Was looking for a client b/c this is fairly general use case. Or I think the handler is the only way in AkkaJava. Please share your comments Thanks and Regards, Ashutosh Prakash Mish

[akka-user] Re: Using the Actor uid

Hello I'd like to ask what exactly is an actor UID? > -- >> 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 --- Y