Re: [akka-user] Delay within GraphStageLogic

Thanks, It fires now. This was a MockSource just for working out how to do error handling. The problem was the tests completed before the timer fired. Gary On Saturday, August 27, 2016 at 12:23:59 AM UTC-7, drewhk wrote: > > > >> > Is this a Source? You omitted the shape... Anyway, it might be

[akka-user] [akka-http] what is actually happening on request timeout?

HI All, I came across a strange issue happening with akka http on request timeout which i cannot understand, can some body help me with it? Consider following code in akka 2.4.9: import akka.NotUsed import akka.actor.ActorSystem import akka.http.scaladsl.Http import

Re: [akka-user] Asynchronous processing in onReceive of Actor

Akka Streams? On Sat, Aug 27, 2016 at 7:53 PM, Kalpak Gadre wrote: > Hi, > > I am using Play Framework 2.5.x Java. I have a use case where I need to > create a process that, > > 1. Polls Amazon SQS for message(s) > 2. For each message, download some file from S3. > 3. Update

[akka-user] Cannot configure mailbox for Routees in RoundRobinPool

Hello everyone, When I try to set a bounded mailbox to routees of RoundRobinPool, Akka, kind of ignores the configuration parameter. Here is the sample for configuration: bounded-mailbox { mailbox-type = "akka.dispatch.BoundedMailbox" mailbox-capacity = 1 mailbox-push-timeout-time =

[akka-user] Can't execute more than 4 requests in parallel

Hi! I'm trying to load test my application using Akka Http client but failing to execute more than 4 requests in parallel. The steps of the test: 1. Create a user 2. Authenticate the user 3. Prepare a request and create a sequence of it to execute in parallel. Here is the code of the function

[akka-user] Asynchronous processing in onReceive of Actor

Hi, I am using Play Framework 2.5.x Java. I have a use case where I need to create a process that, 1. Polls Amazon SQS for message(s) 2. For each message, download some file from S3. 3. Update Mongo with new data as per message. 4. Delete the message from SQS. I have already created

[akka-user] Method to block Migration of Cluster Sharded Actors in a Certain State

I have a cluster shared actor that basically has two states; IDLE and BUSY. The actor is cluster shared because I need the behavior of having only a single one of these in the cluster per user and I want all of the messages that the actor to handle to be serialized per user. The actor mostly

[akka-user] akka connection refused with a shared actorRef

I'm not sure if my problem relies on akka or on network setup. I'm writting a program that uses a server to connect different clients together. The server and the clients are actor system. The problem is that in some contexts, when the clients receives the actorRef of the other clients send

Re: [akka-user] Delay within GraphStageLogic

I'd probably start by implementing the behavior through the built in combinators before venturing into creating custom stages. -- Cheers, √ On Aug 27, 2016 9:23 AM, "Endre Varga" wrote: > > > On Sat, Aug 27, 2016 at 12:44 AM, Gary Struthers

Re: [akka-user] Delay within GraphStageLogic

On Sat, Aug 27, 2016 at 12:44 AM, Gary Struthers wrote: > Sorry, my onTimer() doesn't fire. > That would be surprising given that all of the built-in time based operators are implemented in terms of this. > It looks like all I need to do is 1. use TimerGraphStageLogic

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

The commit commands are emitted to the underlying KafkaConsumer in right order. It is waiting for the results of the commits that are done in parallel, and will possibly increase total throughput. We observed better throughput in performance tests. It would be great to clarify this in docs. You