[akka-user] Example for change in 2.0-M1 stream

Hello, I have a "switch" code shown below in Akka stream 1.0. I'll be totally honest, I don't understand 100% of what's going on here--I reworked it from a sample found someplace. Is there an example somewhere of what an equivalent structure would look like in 2.0-M1? Thanks for any hints!

[akka-user] Cluster Sharding Proxy vs Cluster Client

When should I use Cluster Sharding Proxy and when Cluster Client? I have a backend with sharded actors and HTTP frontend which provide interface for them. The operations mostly fire-and-forget semantics, so HTTP frontend does not return any data to user, but just proxy notifications to sharded

Re: [akka-user] [akka-stream] demand doesn't follow arguments for for grouped or take

On 11/12/2015 07:15 PM, Endre Varga wrote: On Thu, Nov 12, 2015 at 7:09 PM, Simon Schäfer > wrote: On 11/12/2015 06:57 PM, Endre Varga wrote: Hi Simon, This documentation section explains this in more detail: http://doc.akka.io/docs/akka-stream-a

Re: [akka-user] [akka-stream] demand doesn't follow arguments for for grouped or take

On Thu, Nov 12, 2015 at 7:09 PM, Simon Schäfer wrote: > > > On 11/12/2015 06:57 PM, Endre Varga wrote: > > Hi Simon, > > This documentation section explains this in more detail: > http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M1/scala/stream-rate.html > > Ok, I didn't come to that

Re: [akka-user] [akka-stream] demand doesn't follow arguments for for grouped or take

On 11/12/2015 06:57 PM, Endre Varga wrote: Hi Simon, This documentation section explains this in more detail: http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M1/scala/stream-rate.html Ok, I didn't come to that point of the documentation so far. I'm going to have a look, thanks!

[akka-user] [akka-http] Java server with https

Hello, is it possible to have a server handling https connections while using the routing api? Reading the docs, there is support for it in the low-level api but I can't find it exposed while using the "routes dsl"... Thanks in advance! -- >> Read the docs: http://akka.io/docs/ >

Re: [akka-user] [akka-stream] demand doesn't follow arguments for for grouped or take

Hi Simon, This documentation section explains this in more detail: http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M1/scala/stream-rate.html Btw, Sink.head actually does not request more than one, however this is not transitive and cannot be. Grouped cannot possibly know how many el

[akka-user] [akka-stream] demand doesn't follow arguments for for grouped or take

I just tried the following (on 2.0-M1): scala> Source(1 to 100).map{i ⇒ println(i); i}.grouped(10).runWith(Sink.head) 1 2 3 4 5 6 7 8 9 10 11 res10: scala.concurrent.Future[scala.collection.immutable.Seq[Int]] = scala.concurrent.impl.Promise$DefaultPromise@2df79942 12 13 14 15 16 scala> 17 18 1

Re: [akka-user] akka sharding monitoring

Brice, Thanks for the answer. I will definitely have a look into what the events could give me and how the strategy could be tuned to provide such events. tnks, Rod On Thursday, November 12, 2015 at 4:24:27 PM UTC, Brice Figureau wrote: > > On Thu, 2015-11-12 at 07:41 -0800, Rodrigo Boavida wro

Re: [akka-user] akka sharding monitoring

On Thu, 2015-11-12 at 07:41 -0800, Rodrigo Boavida wrote: > > I'm currently starting to implement an Akka sharding based > infrastructure and given the dynamic load balancing nature and > recoverability, part of the monitoring process would be around > monitoring the current shards and entities o

[akka-user] akka sharding monitoring

Hi all, I'm currently starting to implement an Akka sharding based infrastructure and given the dynamic load balancing nature and recoverability, part of the monitoring process would be around monitoring the current shards and entities owned by each shard. Would be nice to know if there is an

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

Hi, I have done some deeper digging into that and it seems that the issue is not the Terminated message not being received. The sharded actor keeps running on both nodes of the cluster! The shard region correctly resolves where to send message so it's hard to spot this as long as you're using

[akka-user] I get strange error with 2.0-M1

I send a request all is working but get this after 2 s I've configured in application.conf akka.http.server.idle-timeout = 2 s Internal server error, sending 500 response java.util.concurrent.TimeoutException: No elements passed in the last 2 seconds. at akka.stream.impl.Timers$IdleBidi$$anon$4.o

[akka-user] Akka cluster failover- race condition

Hi, Node here means one VM. We are using Akka cluster where each node in the cluster assigned to do specific task. If any node in the cluster goes down then MEMBER DOWN event comes up in the cluster. After catching this event other node start processing task assigned to the failure node Thi

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

Hi André, Thanks for your reply, using Mapper works fine (a bit more verbose than the scala implementation) For those who have the same issue: here is the solution: private Future handleGetTask(RequestContext ctx){ return Patterns.ask(actorSystem.actorFor("myActor"), buildMessage(), 1000)