[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

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 se

Re: [akka-user] Re: Pooled Async Actor Architecture

Using that `id` is *safe*. Let me maybe explain by example why closing over sender is not safe when it seems as if it’s the same thing “from the outside"… So `sender()` is not a value, it’s a `def` which has an underlying `var`. That var is changed each time a message arrives to the Actor, to po

[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:

[akka-user] Re: Basic HTTP client with Akka HTTP

I'm also interested in this. Here is a modified example http client and server that work on 0.11 (based on Rüdiger's example): https://gist.github.com/abrighton/acd43a6cd9c0b997c456 Any suggestions are welcome. I also plan to add the capability to upload files using this (with POST), which sh

[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 https://gist.github.co

[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/ >>>

[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 app

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 (soum

[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 Ak

[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 (JNI

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: > https://g

[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 https://github.com/romix/akka-k

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

On Thu, Nov 20, 2014 at 3:31 PM, Allan Brighton 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 server. > Sure. Bas

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_send

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: > > Thi

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

Yeah, was doing "the rounds” on creating tickets etc. Sorry I didn’t ping this thread! :-)  I’ll get back to the other questions in this thread soon today, thanks for your patience! —  konrad On 20 November 2014 at 13:51:17, Adam Warski (a...@warski.org) wrote: I opened GH issues and I see Ko

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 be

[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 листопада 201

[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 yo

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

I'm also unable to download the reproducer (415 error from google drive). Would you be able to share it some other way (git repo?) -- Konrad -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html

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 " On Thu, Nov 20, 2014 at 12:32 PM, Sergii Vozniuk wrote: > Hi Konrad, > > Probably I didn't provide some important inform

Re: [akka-user] Simple Akka + TCP example?

Hi Luc, Have you looked at the examples in the akka-io-tcp section of the docs? Writing to a connection is as simple as opening the connection and then sending Write messages to the connection actor you'll get back from

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 (thin

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 ea

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 for this and we'll have a deeper look into this then? -- Konrad, Akka Team Typesafe - The

Re: [akka-user] Akka stream question

We've focused on getting the representation, materialization and execution -correctness- in place before we start optimizing. Stay tuned. On Thu, Nov 20, 2014 at 3:54 AM, mqshen wrote: > Hi, > > I'm use akka stream 0.10 for StreamTcp data read and decode. > > Source(connection.inputStream) > .

[akka-user] Akka stream question

Hi, I'm use akka stream 0.10 for StreamTcp data read and decode. Source(connection.inputStream) .mapConcat(delimiterFraming.apply) .map(_.utf8String) .map(MessageParser.parse) .filter(_.isSuccess) .map(_.get) .foreach(connectionActor ! _) When I do a performance test. the inputStre

[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 anothe