On Mon, Aug 3, 2015 at 9:39 PM, Patrik Nordwall patrik.nordw...@gmail.com
wrote:
Why do you need to specify the timestamp when you know the sequence number?
While debugging this I also discovered the sequence number was always the
same - I don't have enough understanding to know whether this
Hi all,
I am new to Akka, I have successfully written a simple Akka application
that runs on single machine. Now I want to distribute my application to
multiple nodes available on my standalone cluster. Here is my code. Now if
you see the addr1, it has a port = -1, which should be illegal and
That failure leads to another failure: actor name not unique
08:11:39.893 [sgActors-akka.actor.default-dispatcher-17] ERROR
a.c.ClusterCoreSupervisor: actor name [cluster] is not unique!
akka.actor.InvalidActorNameException: actor name [cluster] is not unique!
--
Read the docs:
Quite often, especially on slower machines (test, intergration) akka
cluster extension timeouts:
08:11:39.642 [sgActors-akka.actor.default-dispatcher-4] ERROR
Cluster(akka://sgActors): Failed to startup Cluster. You can try to
increase 'akka.actor.creation-timeout'.
our take on closing clients and server connection:
http://stackoverflow.com/questions/31706186/how-to-close-connections-in-akka-stream-tcp-server
On Tuesday, July 28, 2015 at 11:25:51 AM UTC-4, dr...@collective.com wrote:
Isn't the paragraph that describes Closing connections in Akka Stream
Hi,
I would like to start different ShardRegions on some different hosts, and
make them communicate with each other.
From the examples I learnt on the internet, I think we can achieve this by
using ShardRegion proxy.
For example, SR1 @ host1 wants to send a message to SR2@host2, the SR1
Hi,
In the documentation Akka Java documentation : Routing [A Simple Router],
ti's discussing how to manage routees whenever it's being terminated. The
sample only deals with 1 router with 5 routees. In my case I'm doing 2
routers with 5 routees each like this:
Akka 2.3.12
public class
Actually that documentation is confusing as heck. I got it working finally
but not by using the ActorRef but rather serializing the ActorPath. Its
much easier. You have to make sure to enable remoting of course.
On Monday, August 3, 2015 at 1:11:48 PM UTC-5, Rafał Siwiec wrote:
Hi kraythe,
Hi kraythe,
I think the simplest solution to serialize/deserialize ActorRef is:
Serialization.serializedActorPath(theActorRef) / extendedSystem.provider().
resolveActorRef(identifier)
as described here:
http://doc.akka.io/docs/akka/snapshot/java/serialization.html#Serializing_ActorRefs
On
Why do you need to specify the timestamp when you know the sequence number?
Anyway, has this been reported as an github issue?
/Patrik
On Mon, Jul 20, 2015 at 5:07 AM, Stephen McDonald stephen...@gmail.com
wrote:
BTW for anyone who hits this issue and needs an immediate solution, here's
how
Hi there,
sorry I missed this thread previously.
This change has some background story to it, but perhaps we missed something
when Criteria is used for the delete...
I'll open a bug and have a look at it. The reason was to abandon the
deleteSnapshot(seqNr, timestamp) API, as the timestamp is
On Mon, Aug 3, 2015 at 1:55 PM, Konrad Malawski
konrad.malaw...@typesafe.com wrote:
Hi there,
sorry I missed this thread previously.
This change has some background story to it, but perhaps we missed
something when Criteria is used for the delete...
I'll open a bug and have a look at it.
On Mon, Aug 3, 2015 at 1:59 PM, Konrad Malawski
konrad.malaw...@typesafe.com wrote:
By looking at the patch it seems it's a bug indeed - would you submit the
patch as a PR Stephen?
I opened up an issue, so you could open a PR referencing the issue nr:
By looking at the patch it seems it's a bug indeed - would you submit the patch
as a PR Stephen?
I opened up an issue, so you could open a PR referencing the issue nr:
https://github.com/akka/akka/issues/18112
Thanks a lot for finding this and the patch!
--
Cheers,
Konrad 'ktoso’ Malawski
14 matches
Mail list logo