Re: [akka-user] Re: akka-persistence: LocalSnapshotStore ignores timestamps in SnapshotSelectionCriteria

2015-08-03 Thread Stephen McDonald
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

[akka-user] Akka Remote Message delivered despite wrong configuration ...

2015-08-03 Thread fbaig
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

[akka-user] Re: 2.3.12. Akka cluster init timeouts

2015-08-03 Thread Marek Żebrowski
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:

[akka-user] 2.3.12. Akka cluster init timeouts

2015-08-03 Thread Marek Żebrowski
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'.

[akka-user] Re: Typo in Akka Stream 1.0 docs ? Closing connections is not working?

2015-08-03 Thread droy
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

[akka-user] Send messages to ShardRegion from another JVM

2015-08-03 Thread Yifei
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

[akka-user] Akka java newbie : Managing different routess within an actor

2015-08-03 Thread apo
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

[akka-user] Re: How can I serializer an ActorRef to another system?

2015-08-03 Thread kraythe
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,

[akka-user] Re: How can I serializer an ActorRef to another system?

2015-08-03 Thread Rafał Siwiec
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

Re: [akka-user] Re: akka-persistence: LocalSnapshotStore ignores timestamps in SnapshotSelectionCriteria

2015-08-03 Thread Patrik Nordwall
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

Re: [akka-user] Re: akka-persistence: LocalSnapshotStore ignores timestamps in SnapshotSelectionCriteria

2015-08-03 Thread Konrad Malawski
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

Re: [akka-user] Re: akka-persistence: LocalSnapshotStore ignores timestamps in SnapshotSelectionCriteria

2015-08-03 Thread Patrik Nordwall
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.

Re: [akka-user] Re: akka-persistence: LocalSnapshotStore ignores timestamps in SnapshotSelectionCriteria

2015-08-03 Thread Patrik Nordwall
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:

Re: [akka-user] Re: akka-persistence: LocalSnapshotStore ignores timestamps in SnapshotSelectionCriteria

2015-08-03 Thread Konrad Malawski
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