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!
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)
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
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
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
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
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
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
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
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/
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,
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
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
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
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:
15 matches
Mail list logo