Re: [akka-user] akka.stream.scaladsl.Flow and flatMap

Hey, the flatMap operator absence is a real pain. I'm actually migrating some Rx code that is basically full of flatMaps to Akka-streams and it is not easy to write custom operator that would do it with 2 days worth of experience. Anybody willing to give me some hints or show some code? Thanks

Re: [akka-user] akka http 1.0-M2 thread pegs a CPU core until connection closes on Windows

I came across the same issue, independent of akka-streams, It seems to be introduced with akka 2.3.7, starting with that version I also observe 100% CPU usage after using any akka io parts. Disabling the setting fixes it. Should this be documented or disabled by default if it affects a lot of u

[akka-user] Akka Cluster Actor Failover and Rebalancing, is it possible?

Hi, I’m looking to see if Akka can be used as a cluster manager instead of say Mesos for my use case. Simply put, my use case is as following: 1. I have 10 physical machines. 2. I need to have 10 *singleton* stateless actors running on each one of these machines. 1 actor per server. 3. If one o

Re: [akka-user] Does akka support fiber/coroutine? (do not modify source code)

On Fri, Feb 6, 2015 at 8:24 PM, wrote: > Hi > > Because my application is running on one thread now. (It maybe extend to > multi-thread in the future) > > To be frank, > > I get benefit from akka by using actor model programming paradigm instead > of its concurrency. > You can use an Akka Dispa

Re: [akka-user] Does akka support fiber/coroutine? (do not modify source code)

Hi Because my application is running on one thread now. (It maybe extend to multi-thread in the future) To be frank, I get benefit from akka by using actor model programming paradigm instead of its concurrency. Br, Chansey 在 2015年2月7日星期六 UTC+8上午2:58:10，√写道： > > Hi Chansey, > > What would y

Re: [akka-user] Is there any way to change actor's hierarchy (eg: orphan actor)

Hi, Thanks for your clarification. But I think orphan should also be a kind of supervisor strategy. (For instance, when a parent detects a failure, all subordinate could become orphaned) Thanks. Br, Chansey 在 2015年2月6日星期五 UTC+8下午5:53:29，Akka Team写道： > > Hi, > > There is no way to change the

Re: [akka-user] Does akka support fiber/coroutine? (do not modify source code)

Hi Chansey, What would you look to gain by switching to coroutines? On Fri, Feb 6, 2015 at 7:44 PM, wrote: > Hello, > > Does akka support fiber/coroutine? > > I found that all akka's dispatchers rely on JVM threads now. > > Is there any way to config dispatchers which could run actor on > fiber

[akka-user] Does akka support fiber/coroutine? (do not modify source code)

Hello, Does akka support fiber/coroutine? I found that all akka's dispatchers rely on JVM threads now. Is there any way to config dispatchers which could run actor on fiber/coroutine? (do not modify the akka source code) Like StubFiber in retLang which use ExecuteAllPendingUntilEmpty to run

Re: [akka-user] Re: new project - akka streams/http - is using the current spray release with akka streams and migrating later too painful?

Brilliant! Thanks for your hard work G On Friday, 6 February 2015 10:10:07 UTC, Akka Team wrote: > > Hi Giovanni, > > Akka Streams will reach 1.0 by the end of this month hopefully. I would > wait for that release because we are still aggressively change things if > they don't feel "right". Fro

Re: [akka-user] Akka stream and akka cluster

Hey Endre, could you share you thought to achieve fault tolerance in akka streams? пятница, 6 февраля 2015 г., 16:07:09 UTC+6 пользователь Akka Team написал: > > Hi Alexey, > > > >> Do you have any plans to implement clustered stream materializer to >> distribute stream parts in cluster? If ye

[akka-user] Best way to write unit tests on an Akka actor

I am a relative newbie to testing Akka actors. What I am trying to accomplish is: How do I unit test the following Actor whose description I have laid out below: *Description:* I am trying to test an Actor class that is peering into a directory, and inspecting the files inside of it. This actio

[akka-user] Location transparency - not clear

Hi – We have been using Akka for some time now as part of our online service (www.sickly.org) and overall have been very happy with it. Having started with creating and running actors locally, on a single server instance, a few months back we started scaling up by moving some actors out onto a

Re: [akka-user] [akka-streams 1.0-M2]: opportunistic FlattenStrategy

Thanks for the quick response, I'll look for FlattenStrategy.merge in future releases. On Friday, February 6, 2015 at 6:00:06 AM UTC-5, Akka Team wrote: > > Hi Paul, > > On Thu, Feb 5, 2015 at 10:50 PM, Paul Kinsky > wrote: > >> I would like to flatten a Source[Source[T]] opportunistically, emit

Re: [akka-user] ANNOUNCE: Akka Streams & HTTP 1.0-M3

And in the rush of course I forgot one thing: Thanks a lot to Greg Beech for adding the “Age” and “Expires” headers to our HTTP model! > 6 feb 2015 kl. 15:56 skrev Roland Kuhn : > > Dear hakkers, > > it has been over a month, so we figured that another milestone of our Streams > & HTTP project

[akka-user] ANNOUNCE: Akka Streams & HTTP 1.0-M3

Dear hakkers, it has been over a month, so we figured that another milestone of our Streams & HTTP projects is in order. The Christmas break was a bit longer on the HTTP side (i.e. not so many changes there), so most of the work went into streams: consistently use the word “failure” instead of

Re: [akka-user] AtLeastOnceDelivery - mapping my own messageId to deliveryId possible?

Hi Pawel, What is the exact problem here? I am a bit slow today, so I might just have missed the obvious, but explaining in detail would help :) -Endre On Wed, Feb 4, 2015 at 10:32 AM, Paweł Kaczor wrote: > According to > http://doc.akka.io/docs/akka/snapshot/scala/persistence.html#Relationshi

Re: [akka-user] Graceful shutdown after persists completes

Hi Avi, I created a ticket for this, you should track progress there: https://github.com/akka/akka/issues/16784 -Endre On Wed, Feb 4, 2015 at 9:09 AM, Avi Levi <123...@gmail.com> wrote: > I am sending heavy rate of messages to the actor that updates it's state > > for (i <-0 to 10){ > per

[akka-user] 2.4-SNAPSHOT and sbt-assembly :(

Hello. I tried to build a fat jar using sbt-assembly plugin and got the following error: [error] (robot/*:assembly) deduplicate: different file contents found in the following: [error] /home/eax/.ivy2/cache/org.iq80.leveldb/leveldb-api/jars/leveldb-api-0.7.jar:org/iq80/leveldb/DB.class [error]

Re: [akka-user] [akka-streams 1.0-M2]: opportunistic FlattenStrategy

Hi Paul, On Thu, Feb 5, 2015 at 10:50 PM, Paul Kinsky wrote: > I would like to flatten a Source[Source[T]] opportunistically, emitting > elements of type T as they arrive from any of the inner Sources. This is > conceptually similar to a merge vertex >

Re: [akka-user] Re: Send message from netty code to actor system

Few things to take care of using a router at InboundHandler - ensuring that routees are available before the connections are being accepted - ensuring that ChannelContextHandler - passed in message, is not stored by routee actor internally for any purposes. This should be sufficient for pure r

Re: [akka-user] Recovering from the Quarantined state

You should probably also look into why they are quarantined. It can be two reasons: 1) The nodes are removed from the cluster, which will happen if failure detection triggers, you use auto-downing and they don't become reachable again within the configured akka.cluster.auto-down-unreachable-after

Re: [akka-user] Re: new project - akka streams/http - is using the current spray release with akka streams and migrating later too painful?

Hi Giovanni, Akka Streams will reach 1.0 by the end of this month hopefully. I would wait for that release because we are still aggressively change things if they don't feel "right". From 1.0 the pace of change will be (at least from the API point of view) slower. -Endre On Wed, Feb 4, 2015 at 2

Re: [akka-user] Akka cluster unreachable

Hi Idar, Happy to hear that, and thanks for the confirmation. -Endre On Wed, Feb 4, 2015 at 9:08 AM, Idar Borlaug wrote: > I have upgraded to 2.3.9 it have now been running for 5 days, without any > problems. > > On 28 January 2015 at 11:50, Idar Borlaug wrote: > >> I know, we have a few prob

Re: [akka-user] Akka stream and akka cluster

Hi Alexey, > Do you have any plans to implement clustered stream materializer to > distribute stream parts in cluster? If yes do you have any estimations or > ETA? > Yes, we have such plans, but currently no "official plans". Which means that we want to do it, but not yet sure when. > > Righ

Re: [akka-user] Linking actors after creation

On Tue, Feb 3, 2015 at 6:25 PM, Viktor Klang wrote: > Hi Ugo, > > Thanks for your question! > > No, Akka does not support any notion of "adoption". > On the other hand there is the alternative, which is DeathWatch: http://doc.akka.io/docs/akka/2.3.9/scala/actors.html#Lifecycle_Monitoring_aka_Dea

Re: [akka-user] Recovering from the Quarantined state

Hi Mark, On Tue, Feb 3, 2015 at 5:13 PM, Mark Kegel wrote: > We are using akka 2.3.4, but I don't think this is an issue with a > specific version of akka. In fact the docs explicitly state that you have > to restart the akka node after its been Quarantined. > > I'm looking for some way to detec

Re: [akka-user] Akka HTTP - back-pressure on incoming connections

Hi Luis, Not directly solving your problem, but a related pattern can be found in the cookbook: http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala/stream-cookbook.html#Globally_limiting_the_rate_of_a_set_of_streams I assume that recipe can be adapted in various ways to differe

Re: [akka-user] Is there any way to change actor's hierarchy (eg: orphan actor)

Hi, There is no way to change the hierarchy because parent-child relationship between actors mean a supervision link which cannot be broken. The problem here is that you try to use the supervision hierarchy to model a completely unrelated data structure which is not about supervision but "storage"

Re: [akka-user] Trying to persist heavy load cause a strange crash

Hi Avi, This seems to be a possible bug. Can you create a small code snippet that reproduces the issue and file a ticket to our issue tracker: https://github.com/akka/akka/issues -Endre On Tue, Feb 3, 2015 at 2:58 PM, Avi Levi <123...@gmail.com> wrote: > Hi , > I want to start using actors with