[akka-user] AKKA cluster remoting taking time

Hi, I have two node system one running on 2551 port and other running on 2552 port on single machine right now. I am sending object containing 1 records from 2551 to 2552 and the payload size is less then 1 Mb and it's taking around 60 to 70 millisecond for transfer from one node to

Re: [akka-user] Akka allocates new socket for each unsuccessful connection attempt to a quarantined system.

Hi Sergii, This sounds like a potential bug. I tried to trace this back to something obvious in the code but didn't find anything yet. Would you mind creating an issue https://github.com/akka/akka/issues for this and we'll have a deeper look into this then? -- Konrad, Akka Team Typesafe - The

Re: [akka-user] Any update regarding Akka 3.0?

Hi Ryan, while this is nothing official, here's one of the branches Roland is experimenting on: https://github.com/rkuhn/akka/tree/wip-g%C3%A5lbma-step1/akka-typed Not sure if that's the latest and greatest (branch), probably it is. Please treat this as random draft and ideas, it's not even an

Re: [akka-user] routing and load balancing with AKKA instead of regular NLB

On top of that - of course we will continue to POC. As I mentioned we are confident with Akka and using it's advantages BUT since we are new to Akka, we had some debate and one argument was let NLB do what it knows and let the application do it's part. Because that we understand (think :))

Re: [akka-user] Akka allocates new socket for each unsuccessful connection attempt to a quarantined system.

*Anti-virus warning* - 1 attachment contains a virus or blocked file. Downloading this attachment is disabled. Learn more https://support.google.com/mail/answer/6590?hl=en On Thu, Nov 20, 2014 at 12:32 PM, Sergii Vozniuk ser...@vozniuk.com wrote: Hi Konrad, Probably I didn't provide some

[akka-user] Re: Akka allocates new socket for each unsuccessful connection attempt to a quarantined system.

Sorry I don't know why google thinks there is a virus, or why it didn't allow the zip. I'll try to share it in some other way. Четвер, 20 листопада 2014 р. 12:48:31 UTC+1 користувач Konrad Malawski написав: I'm also unable to download the reproducer (415 error from google drive). Would you

[akka-user] Re: Akka allocates new socket for each unsuccessful connection attempt to a quarantined system.

Here https://github.com/svozniuk/akka-sockets-issue Четвер, 20 листопада 2014 р. 13:04:52 UTC+1 користувач Sergii Vozniuk написав: Sorry I don't know why google thinks there is a virus, or why it didn't allow the zip. I'll try to share it in some other way. Четвер, 20 листопада 2014 р.

Re: [akka-user] Reactive actor-actor communication

I opened GH issues and I see Konrad beat me to it: https://github.com/akka/akka/issues/16348 :) Adam On Wednesday, November 19, 2014 8:36:41 AM UTC+2, rkuhn wrote: Hi Adam, your initial point of creating a growing (and maybe thundering) herd of retries is a good one and it would be better

Re: [akka-user] akka-http (experimental) file server

Thanks for the http server example. It works fine. Do you also have a matching example for the client side? I found akka.http.TestClient, which is a start, but does not give any hints about reading the data from the server. On Wednesday, November 19, 2014 9:35:18 PM UTC+1, rklaehn wrote: This

Re: [akka-user] Pooled Async Actor Architecture

Hi David and welcome to Scala/Akka! Your design looks pretty OK :-) I'll comment on a few things and you questions in-line, below: class MyDBClient extends Actor{ val client = Client( 102.98.2.1:3000 ) def receive = { case ReadCommand( id ) = val orig_sender =

Re: [akka-user] akka-http (experimental) file server

On Thu, Nov 20, 2014 at 3:31 PM, Allan Brighton allane...@gmail.com wrote: Thanks for the http server example. It works fine. Do you also have a matching example for the client side? I found akka.http.TestClient, which is a start, but does not give any hints about reading the data from the

[akka-user] Akka Persistence and Kryo serialization

I thought I'd experiment with using akka-kryo serializer to see what difference it made to performance of persisting an event (defined by a simple case class) compared to just allowing the default java serialization after trying to follow the instructions in here

Re: [akka-user] Any update regarding Akka 3.0?

Please treat this as random draft and ideas, it's not even an early preview *yet*. Understood! Thanks On Thursday, November 20, 2014 3:24:58 AM UTC-7, Konrad Malawski wrote: Hi Ryan, while this is nothing official, here's one of the branches Roland is experimenting on:

[akka-user] Using Akka Persistence with another KV store

My understanding is Akka Persistence uses LevelDB as the default journal. I want to evaluate another KV store that similar to LevelDB. How easy/hard is it to replace the LevelDB with the new KV store. The store is written in C. I'm assuming Akka persistence calls LevelDB API using a wrapper

[akka-user] Re: Using Akka Persistence with another KV store

Looks like Akka persistence uses a Java port of LevelDB (https://github.com/dain/leveldb). So now my question what is the recommended way of using the new KV as the persistence journal? Thanks. On Thursday, November 20, 2014 10:41:04 AM UTC-5, Soumya Simanta wrote: My understanding is

Re: [akka-user] Using Akka Persistence with another KV store

Here’s all you need to know on how to implement your own journal plugin:  http://doc.akka.io/docs/akka/snapshot/scala/persistence.html#journal-plugin-api Here are the existing plugins: akka.io/community#plugins-to-akka-persistence happy hakking On 20 November 2014 at 16:41:07, Soumya Simanta

[akka-user] Use TypedActor or something else

In one of threads (https://groups.google.com/forum/#!searchin/akka-user/Best$20way$20to$20integrate$20akka$20into$20a$20legacy$2Fexisting$20app/akka-user/SDHSJxjNYSY/cZgAdUklC28J) user Akka team write Typed actors are no longer recommended, we will eventually phase them out I already have

[akka-user] AKKA KRYO causing cluster node unregister

Hi, I have two node system which was working fine till i have added the kryo. Attached file is the application.conf that i am using. KRYO causing the other node unregistered. do i need to change something in the configuration -- Read the docs: http://akka.io/docs/ Check the

[akka-user] Basic HTTP client with Akka HTTP

Hi all, It looks like the syntax of handling client HTTP streams are under rapid revision, but I wanted to build a client with 0.11 anyway. I've found some examples, but none of them are quite up-to-date. If anyone cares to contribute, a little discussion is going on at

[akka-user] Re: Pooled Async Actor Architecture

Thanks very much for your reply, Konrad. Could you tell me if the state of id is preserved when the future returns? I would assume No, since I don't see how I'm freezing the state of id when the future returns. class ConfirmationCalc( dbClient:ActorRef ) extends Actor{ def receive:Receive

Re: [akka-user] Confusion about durable mailboxes superseded by akka-persistence?

Hi, As per the suggestion, I implemented a QueueActor, which will saveSnapshot for every message it receives or removed. And then a ProcessActor, which will read the message from the QueueActor to process it. Is this the right way to implement durable mailbox with akka-persistence? Problem I

[akka-user] Save 2 snapshots at the same time?

Hi, In my code, I am saving snapshots frequently (For every message received by the Actor, to achieve durability) I was going thru the LocalSnapshotStore code and found that snapshots are stored with current_time_millisec as filename. What if my code saves 2 snapshot at the same millisec? Will