Re: [akka-user] Sharding performance: Mailboxes.getMailboxType

What does the test do? How many actors are created per second? Why is it creating so many actors so that the mailbox creation becomes a bottleneck? /Patrik On Fri, May 6, 2016 at 1:56 PM, Yegor Andreenko wrote: > I have a poor Sharding performance and tried to profile application with > only on

Re: [akka-user] [2.4.4] connection level http client Api misses requests

I lied, I can confirm this fails for both but it fails earlier for cachedConnectionPool 2016-05-06 11:20 GMT+01:00 Edmondo Porcu : > An update : switching from cachedConnectionPool to newHostConnectionPool > solve the issue > > Sent from my iPhone > > > On 6 May 2016, at 10:54, Edmondo Porcu > w

[akka-user] akka-persistence deliver doesn't work with SupervisorStrategy

Hello, I am having a problem to apply SupervisorStrategy to an Actor. The below is the scenario: The parent *actor (A)* extends from *AbstractPersistentActorWithAtLeastOnceDelivery* has a SupervisorStragegy defined there and deliver a message to child *Actor (B*) @Overr

Re: [akka-user] Native LevelDB crashes Akka tests

I have not tested *IF* simple version revert fixes the problem On Friday, May 6, 2016 at 5:29:00 PM UTC-4, Paul Roman wrote: > > Thanks for the offer. It worked with 2.3.7 and 2.3.9, I believe. I have > not tested with simple version revert fixes the problem. > > Current versions: > Akka version:

Re: [akka-user] Native LevelDB crashes Akka tests

Thanks for the offer. It worked with 2.3.7 and 2.3.9, I believe. I have not tested with simple version revert fixes the problem. Current versions: Akka version: 2.3.15 Native LevelDB: 1.18 (installed via brew) JRE version: Java(TM) SE Runtime Environment (8.0_45-b14) (build 1.8.0_45- b14) Java V

Re: [akka-user] Re: Injecting messages on inactive stream

LOL, me too – totally forgot we have that one...! Of course we do. Happy hakking / Have a nice weekend :-) --  Konrad `ktoso` Malawski Akka @ Lightbend On 6 May 2016 at 19:15:38, rklaehn (rkla...@gmail.com) wrote: Never mind. I guess I should stop coding and just enjoy the nice weather... http:

[akka-user] Re: Injecting messages on inactive stream

Never mind. I guess I should stop coding and just enjoy the nice weather... http://doc.akka.io/docs/akka/2.4.4/scala/stream/stream-cookbook.html#injecting-keep-alive-messages-into-a-stream-of-bytestrings On Friday, May 6, 2016 at 7:08:56 PM UTC+2, rklaehn wrote: > > Hi all, > > I am currently por

Re: [akka-user] Injecting messages on inactive stream

We don't have a built-in for that, however the ping case has come up rather often, so I'd actually be in favour of including such an op along with the timer based ones we already have. Would you be interested in making a GraphStage which does this and we'd possibly pull it in along the existing

[akka-user] Injecting messages on inactive stream

Hi all, I am currently porting some code using spray websockets to akka-http. I need to inject a ping message into a stream to the client when no message has been sent for some predefined duration. Of course I could just merge with a regular stream of pings, but that would send unnecessary ping

[akka-user] Re: DI and Testing Streams

I just re-read: http://techblog.realestate.com.au/to-kill-a-mockingtest/ It's hard for me to see how to apply this thinking to a side effect like alsoTo() , used for monitoring in my application. On the input side, to make "pure" a function that creates a flow that's built of multiple sources (us

Re: [akka-user] Akka client behind nat issue

In Akka 2.3.x it's only available in Reactive Platform – sa...@lightbend.com  for more information; since it's legacy support basically. In Akka 2.4.x it's available just-so. --  Konrad `ktoso` Malawski Akka @ Lightbend On 6 May 2016 at 14:50:43, enovo.s...@gmail.com (enovo.s...@gmail.com) wrote

Re: [akka-user] Akka client behind nat issue

Hi, But those configurations are not available in aka 2.3.8, Am i missing something? How to achieve the same in akka 2.3.8? Best Regards On Friday, May 6, 2016 at 4:10:39 PM UTC+5, √ wrote: > > Hi Abud, > > On Fri, May 6, 2016 at 12:34 PM, > wrote: > >> >> Hi, >> Thank you for quick reply. >>

[akka-user] Sharding performance: Mailboxes.getMailboxType

I have a poor Sharding performance and tried to profile application with only one local shard. Methods | Cpu Time | % Cpu akka.remote.RemoteActorRefProvider.actorOf(ActorSystemImpl, Props, InternalActorRef, ActorPath, boolean, Option, boolean, boolean) 9512ms 70% akka.actor.LocalActorRefProvide

Re: [akka-user] Akka client behind nat issue

Hi Abud, On Fri, May 6, 2016 at 12:34 PM, wrote: > > Hi, > Thank you for quick reply. > My requirement is: > - Client from behind NAT initiates a connection, sends a message (using > ask pattern) and receives the reply, can we not achieve it using akka > remoting? > > Latest Akka version suppo

[akka-user] Ideomatic way to do local pubsub in akka

I'm started to work with akka as scala actors become deprecated in favour of akka. So I'm intrested only in local actor systems for now. What is intended way to implement publisher subscriber template in akka? Akka gives multiple choice, I found three already: - Store subscribers manually in

Re: [akka-user] Akka client behind nat issue

Hi, Thank you for quick reply. My requirement is: - Client from behind NAT initiates a connection, sends a message (using ask pattern) and receives the reply, can we not achieve it using akka remoting? Latest Akka version supports remoting behind NAT http://doc.akka.io/docs/akka/snapshot/j

Re: [akka-user] [2.4.4] connection level http client Api misses requests

An update : switching from cachedConnectionPool to newHostConnectionPool solve the issue Sent from my iPhone > On 6 May 2016, at 10:54, Edmondo Porcu > wrote: > > The following snippet fails on certain server. I feel this might have to do > with the connection keep alive settings ? > > >

Re: [akka-user] [2.4.4] connection level http client Api misses requests

The following snippet fails on certain server. I feel this might have to do with the connection keep alive settings ? package org.poredm.test import akka.actor._ import akka.http.scaladsl.Http import akka.http.scaladsl.model.HttpResponse import akka.stream.{ActorMaterializerSettings, ActorMater

Re: [akka-user] Illegal to close over saveSnapshot within persistAll

Aha! Thanks I'll look at that. /Magnus fre 6 maj 2016 kl 10:43 skrev Konrad Malawski : > BTW: If you want to store the snapshot after the persistAll has called all > its callbacks you could instead do defer { saveSnapshot }. > > -- > Konrad `ktoso` Malawski > Akka @ Lightbend

Re: [akka-user] Re: [Akka-stream|http] - How to close a flow with killswitch from outside?

Hi You're right, I read the buffer as being the input buffer not the output buffer. As for the kill switch I haven't used it myself so I'm not much help there, I thought the underlying assumption was wrong. /Magnus tors 5 maj 2016 kl 09:56 skrev hamid : > Thank you for the reply. > > First, I w

Re: [akka-user] Illegal to close over saveSnapshot within persistAll

BTW: If you want to store the snapshot after the persistAll has called all its callbacks you could instead do defer { saveSnapshot }. --  Konrad `ktoso` Malawski Akka @ Lightbend On 6 May 2016 at 10:41:02, Magnus Andersson (mag...@magnusart.com) wrote: Hi Yes, the buffer.isEmpty and checkSnaps

Re: [akka-user] Illegal to close over saveSnapshot within persistAll

Hi Yes, the buffer.isEmpty and checkSnapshotTreshold will guarantee the snapshot at most called once per persistAll, when buffer is empty. I also modified it so that trySnapshot would take the State as an argument from the calling persist all. Not sure if that was necessary but it seems to be

Re: [akka-user] Akka client behind nat issue

Hi Abud, Akka Remote is not a client-server protocol, it is a p2p protocol. If you want to use asymmetric communication (where nodes are not symmetrically reachable), use Akka IO. On Fri, May 6, 2016 at 9:57 AM, wrote: > > Hi, > I am working on a simple client server application using akka (2.

[akka-user] Akka client behind nat issue

Hi, I am working on a simple client server application using akka (2.3.8) remoting, can not use latest version of akka due to java 8 dependency. My client is behind NAT and server is listening on port 80. Here are the configurations for both client and server. *Client* *Configs* akka { acto

[akka-user] `No elements passed in the last 1 minute` error in Http().superPool

Hi, we're getting `No elements passed in the last 1 minute` error in Http().superPool, on sending messages after some time; which is natural considering the way idle-timeout is configured, but should the pool perform an auto-reconnect on the first send after the period of in-activity ? Unfortu

[akka-user] Re: Using materialized values from stages

Hi Durga, I'm not sure. Please open a ticket describing what you think should be added and we can take the discussion there, thanks! -- Johan Andrén Akka Team, Lightbend Inc. On Wednesday, May 4, 2016 at 12:22:07 PM UTC+2, Durga Prasana wrote: > > Hi Johan, > > That should work. However, solvi