Re: [akka-user] Accessing SourceQueue or ActorRef inside Graph for publishing elements

tx.push(rotated) } Am Montag, 23. November 2015 12:33:28 UTC+1 schrieb Akka Team: > > Hi Muki, > > > > On Sun, Nov 22, 2015 at 4:49 PM, Muki <nepomuk...@gmail.com > > wrote: > >> Hi, >> >&

[akka-user] Accessing SourceQueue or ActorRef inside Graph for publishing elements

aterialized value inside the Graph" <http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M1/scala/stream-graphs.html#Accessing_the_materialized_value_inside_the_Graph>, but couldn't figure out how to implement this kind of pattern. Thanks in advance, Muki -- >>

[akka-user] Re: Websockets with Elasticsearch ScrollPublisher - Requesting more elements

Hi, I implemented a working solution and will soon provide it as an activator template. https://github.com/muuki88/akka-http-elasticsearch cheers, Muki Am Freitag, 2. Oktober 2015 17:29:09 UTC+2 schrieb Muki: > > Hi, > > I'm playing around with akka-http and elasti4s reactive e

[akka-user] Flatten and grouping streams yields 'exceeding it's subscription-timeout'

) println(result) system.shutdown() system.awaitTermination() } which is not working as expected. I'm not sure where I'm messing things up. The order of operations *concat -> groupBy ( and fold) -> flatten* don't seem to work. thanks, Muki -- >>>>>&g

Re: [akka-user] Flow/Stage from reactive Publisher

concat) .fold[TrajectoryBoxes](TrajectoryBoxes(Nil))(_ :+ _) cheers, Muki Am Dienstag, 22. September 2015 11:41:50 UTC+2 schrieb Patrik Nordwall: > > Have you looked at flatten (concat)? > /Patrik > > On Sun, Sep 20, 2015 at 2:57 PM, Muki <nepomuk...@gmail.com > > wrote

[akka-user] Flow/Stage from reactive Publisher

.mapAsync(parallelism = 1) { polygon => val sink = Sink.fold[Seq[RichSearchHit], RichSearchHit](Seq.empty[RichSearchHit])(_ :+ _) source(polygon).runWith(sink) } thanks in advance, Muki -- >>>>>>>>>> Read the docs: http://akka.io/docs/

[akka-user] Re: Akka Cluster Project - Monolithic JAR or JARs per service?

compatibility, etc.) I'm really interested in other user suggestions :) cheers, Muki -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received

[akka-user] Re: Play + Akka Cluster Aware Routing?

-cluster-sample cheers, Muki Am Dienstag, 9. Dezember 2014 20:08:03 UTC+1 schrieb kraythe: Greetings, I have a question about the interaction of play and Akka in a cluster. Assume I have an actor that sends asynchronous notifications over a web socket using Atmosphere framework (yes I

[akka-user] Re: [ANNOUNCE] Akka Streams HTTP 1.0 MILESTONE 1

, Muki Am Donnerstag, 4. Dezember 2014 18:08:30 UTC+1 schrieb rkuhn: Dear hakkers, we are very pleased to announce the availability of the first milestone release of the upcoming Akka Streams and Akka HTTP modules. The significance of this milestone is that we have roughly reached feature

[akka-user] Akka Streams Transformer

options I see don't look ideal to me class GridCellTransformer { def apply(update: LocationUpdate): Seq[IndexedLocationUpdate] = Nil } val t = new GridCellTransformer geoSource.map(t.apply) or geoSource.map { val buffer = ...; x = toIndexed } thanks :) Muki -- Read the docs: http

Re: [akka-user] Akka Streams Transformer

Compressor(…)) Does that help? :-) On Sun, Nov 16, 2014 at 8:44 PM, Muki nepomuk...@gmail.com javascript: wrote: Hi, I'm currently trying to build a real-time geo-indexing application with akka streams. In order to index my location updates I have to buffer them in a Transformer and map them

[akka-user] Re: Akka architecture pattern vs typed actors

in overengineering stuff you actually can solve a lot easier. Maybe it's a nice starter for beginners as you mentioned. thanks again, Muki PS: Yeah, I'll try to pull an activator out of this Am Donnerstag, 31. Juli 2014 09:52:34 UTC+2 schrieb Michael Pisula: Hi Muki, I like the pattern. In details I

[akka-user] Akka architecture pattern vs typed actors

around typed actors. cheers, Muki -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google

Re: [akka-user] Re: Play and Akka in one Cluster

Hi Martynas, Thanks a lot for taking some time to go through my code. I just published the activator template play-akka-cluster-sample http://typesafe.com/activator/template/play-akka-cluster-sample cheers, Muki Am Freitag, 11. Juli 2014 12:22:39 UTC+2 schrieb Martynas Mickevičius: Hi

Re: [akka-user] Re: Play and Akka in one Cluster

Hi, I finished the first prototype for my activator template: https://github.com/muuki88/activator-play-cluster-sample If you have any feedback regarding does/donts and best-practices on the cluster configuration, I would change this before publishing as an activator. thanks, Muki Am

[akka-user] Re: Play and Akka in one Cluster

* actor. thanks, Muki Am Montag, 7. Juli 2014 23:02:16 UTC+2 schrieb Muki: Hi, I'm currently starting to learn more about akka's cluster feature. My goal is to have separate frontend and backend which are part of the same cluster, so I can - Start jobs on backend akka-nodes from

[akka-user] Play and Akka in one Cluster

use remoting instead of clustering? I tried solution number 1, but the websocket actors couldn't be created, because *ActorRefClusterProvider* wasn't configured (but it's in the config, when I log it via system.logConfiguration). thanks for any advice, Muki -- Read the docs: http

Re: [akka-user] Re: Future time out

@Giovanni it could be the idle status in my case, too. My app is rarely used and I have an actor per shard, which makes them even less used. @Roland This is an interesting point. My setup is very basic. No cluster, no extra config, not even high-load and still there's a chance of loosing reply