Re: [akka-user] Help: how to persist different actor types in different shard regions?

Um -- I *am* an application developer, a heavy user of Cluster Sharding and Persistence. I'm not part of the implementation team... On Fri, Feb 10, 2017 at 12:42 PM, Qing Zheng wrote: > An akka actor provides location transparency. The logical path of an actor > hides the

Re: [akka-user] Sharding not working when I set min-nr-of-members = 3

Hi Patrik, OK, thank you. On Friday, 10 February 2017 23:06:26 UTC+8, Patrik Nordwall wrote: > > Yes, that is the reason. The proxies are not counted. I understand that > this might be confusing. Could you please create an issue > . I have to think about

Re: [akka-user] About Akka persistent redis

Thank you Vadim, you solved my problem. On Saturday, 11 February 2017 01:02:11 UTC+8, Vadim Chelyshov wrote: > > It does not published in maven central. > I should add jcenter repository in yours build defenition. > > 2017-02-10 17:53 GMT+03:00 Dai Yinhua : > >> Hi Julien,

Re: [akka-user] About Akka persistent redis

Thank you Vadim, you solved my question. On Saturday, 11 February 2017 01:02:11 UTC+8, Vadim Chelyshov wrote: > > It does not published in maven central. > I should add jcenter repository in yours build defenition. > > 2017-02-10 17:53 GMT+03:00 Dai Yinhua : > >> Hi Julien,

[akka-user] snapshotSequenceNr

What is the purpose of this method? It just returns lastSequenceNr. I'm implementing an API to delete unneeded events and snapshots. It seems I will have to store (in memory) the metadata provided with SnapShotOffer. That's fine, I'm just curious what the purpose of snapshotSequenceNr is. I

[akka-user] Akka ACID

Hi All, I am trying to evaluate Akka for one of our use cases. Is there any standard pattern to implement ACID transactions in Akka? Also is there any recommended orchestration tools that we can use for Akka APIs? -- >> Read the docs: http://akka.io/docs/ >> Check the

Re: [akka-user] Help: how to persist different actor types in different shard regions?

An akka actor provides location transparency. The logical path of an actor hides the detail implementation from an application developer. I know I can do it with some prefix, which means every application developer has do similar things. If that is the case, would it better to provide a default

Re: [akka-user] About Akka persistent redis

It does not published in maven central. I should add jcenter repository in yours build defenition. 2017-02-10 17:53 GMT+03:00 Dai Yinhua : > Hi Julien, >>> >> > Yes, I think below is the corresponding maven format. > > > com.hootsuite > akka-persistence-redis_2.11 >

[akka-user] ANNOUNCE: Akka 2.4.17 Security Patch Released

Dear hakkers, This is to announce the immediate availability of a security patch release, addressing a potential security issue with Java deserialization. An attacker that can connect to an ActorSystem exposed via Akka Remote over TCP can gain remote code execution capabilities in the context of

Re: [akka-user] Sharding not working when I set min-nr-of-members = 3

Yes, that is the reason. The proxies are not counted. I understand that this might be confusing. Could you please create an issue . I have to think about what we should do about it. At least it should be documented, and maybe it would be better with a separate

Re: [akka-user] Sharding not working when I set min-nr-of-members = 3

Hi Patrik, > > Two of them using ClusterSharding.get(m_actorSystem).start One of them using ClusterSharding.get(m_actorSystem).startProxy So actually I want one as an endpoint, and two servers act as worker node. Is that the reason? -- >> Read the docs: http://akka.io/docs/

Re: [akka-user] About Akka persistent redis

> > Hi Julien, >> > Yes, I think below is the corresponding maven format. com.hootsuite akka-persistence-redis_2.11 0.6.0 But I can't find it from https://repo1.maven.org/maven2/ -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] Re: akka.pattern.Patterns.after and akka.pattern.after

akka.pattern.Patterns.after is the Java API, you should use akka.pattern.after from Scala. It's anyway somewhat interesting, the Java API has two methods with signatures def after[T](duration: FiniteDuration, scheduler: Scheduler, context: ExecutionContext, value: Callable[Future[T]]): Future[T]

[akka-user] Re: Problem detecting Websocket failure

Hello! I also can't get flow.alsoTo(Sink.onComplete(...)) to trigger. The only thing that completes when the websocket closes (due to timeout) is the materialized Future[Done] from the Flow. In addition, the pattern to use for reconnection logic becomes unclear because the websocket flow is

Re: [akka-user] About Akka persistent redis

The required dependency and resolved is described in the readme: https://github.com/hootsuite/akka-persistence-redis#akka-24x-and-play-25x (it's in sbt format, but you can translate easily in maven format) On Friday, February 10, 2017 at 2:31:13 PM UTC+1, Justin du coeur wrote: > > Where did

Re: [akka-user] Sharding not working when I set min-nr-of-members = 3

So you have 3 nodes running. Are you sure that you have started ClusterSharding on all 3 nodes? /Patrik On Wed, Feb 8, 2017 at 3:11 AM, Dai Yinhua wrote: > Hi team, > > I am using cluster sharding function, and it's working. > But after I added *min-nr-of-members = 3* to

Re: [akka-user] PersistentActor Journal writes stop after a time with persistAsync

Sorry for delay here. That sounds strange. It would be interesting if you could narrow it down and create an issue. A reproducer would be great. Regards, Patrik On Tue, Jan 17, 2017 at 8:56 AM, Richard Ney wrote: > > I'm having an issue where the journalBatch queue is

Re: [akka-user] Help: how to persist different actor types in different shard regions?

I agree with Justin :) You could also define different persistence plugins (using different journal tables) for the different types of actors if you want full isolation. On Fri, Feb 10, 2017 at 2:35 PM, Justin du coeur wrote: > I don't know that we're going to agree here,

Re: [akka-user] Help: how to persist different actor types in different shard regions?

I don't know that we're going to agree here, but I *do* strongly disagree. They're independent libraries, and people use each exclusively of the other. There mustn't be cross-dependencies. And I have to admit, I don't understand what the problem is. I simply use a different naming convention

Re: [akka-user] About Akka persistent redis

Where did you get those settings from? On Thu, Feb 9, 2017 at 7:11 PM, Dai Yinhua wrote: > Well, I'm using below maven settings as the document provided. > > > com.hootsuite > akka-persistence-redis_2.11 > 0.6.0 > > > > On Thursday, 9 February 2017 21:38:49 UTC+8,

[akka-user] Re: Can I use Akka for such kind of architecture?

Hi Christian, Another possibility is to use Vert.x for the HTTP (with or without websockets) embedded with Akka if you find Akka Streams overwhelming which is what I have done, I have websockets via Vert.x and each socket connection creates an actor which basically have a mailbox (a queue)

[akka-user] Re: Can I use Akka for such kind of architecture?

Hi Rafał, many thanks. I think I have it now! Best regards, Christian Am Donnerstag, 9. Februar 2017 16:19:41 UTC+1 schrieb Rafał Krzewski: > > The client in private network opens the connection to the server in DMZ. > WebSocket protocol allows bi-directional communication: the server may push

Re: [akka-user] What is the difference between using broadcasts and manually connecting shapes

What does the test output show? On Fri, Feb 10, 2017 at 5:30 AM, faiz halde wrote: > I wanted to know if there is any difference between the following two > scenarios > > val g = RunnableGraph.fromGraph(GraphDSL.create() { implicit builder: > GraphDSL.Builder[NotUsed] =>

[akka-user] What is the difference between using broadcasts and manually connecting shapes

I wanted to know if there is any difference between the following two scenarios val g = RunnableGraph.fromGraph(GraphDSL.create() { implicit builder: GraphDSL.Builder[NotUsed] => import GraphDSL.Implicits._ s ~> f1 ~> si s ~> f2 ~> si ClosedShape }).run() val g =