[akka-user] Re: Update http routes

Hi, Did you solve this? I need to add http routes dinamically. Regards, Ubaldo El jueves, 24 de diciembre de 2015, 6:17:27 (UTC-3), greg@bcgdv.com escribió: > > Hi, > > for my scenario, I need to modify http routes dynamically at runtime by > one of the actors. Can I do it without

[akka-user] Dynamically add HTTP Routes

Hi, I'm trying to dynamically add http routes to a server without restarting Is it possible? I'm using Akka-http Regards Ubaldo -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >>

Re: [akka-user] scan and map

Hi, you can do that using scan with something like this (not compiled): flow.scan(zero = (0, 0)) { case ((prevScan, prevElem), elem) => (prevScan, elem) } On Thu, Jan 28, 2016 at 6:05 PM, Richard Rodseth wrote: > In akka-streams, scan is like fold, in that it takes a

Re: [akka-user] scan and map

On Fri, Jan 29, 2016 at 1:21 PM, Martynas Mickevičius < martynas.mickevic...@typesafe.com> wrote: > Hi, > > you can do that using scan with something like this (not compiled): > > flow.scan(zero = (0, 0)) { > case ((prevScan, prevElem), elem) => (prevScan, elem) > } > Almost, you missed the

Re: [akka-user] Akka Remote via UDP only responds to first client. Timeouts for any others that connect.

Can you look if after first successful connection ActorSystem0 is still bound to the 4201 port? The port should be listed in the output of *ss -ua* command. On Thu, Jan 28, 2016 at 8:08 PM, Chris Benninger wrote: > Hi guys, > > I'm trying to get Akka Remote actors

Re: [akka-user] Akka 2.4.1 cluster ShardCoordinator not starting

Hi, did you configure any persistence journal plugin and have journal backend ready? For testing and playing around purposes you can use in-memory journal plugin by adding these two configuration lines *# use the journal plugin provided with akka* *akka.persistence.journal.plugin =

Re: [akka-user] Dynamic flow multiplexer

Hi Jakob, Perhaps create a fanout Publisher from the Sink and materialize the consumers as Subscribers and connect them to the Publisher? -- Cheers, √ On Jan 28, 2016 6:28 AM, "Jakob Odersky" wrote: > What is the best approach to "connecting" streams at run-time? > > My

Re: [akka-user] Akka 2.4.1 cluster ShardCoordinator not starting

Note that the leveldb journal can't really be used with Cluster Sharding, because it is a local only journal. Yes, you can play with it with one cluster node, otherwise you need to a distributed journal, such as akka-persistence-cassandra . Have

Re: [akka-user] Trying to configure ActorSystems

Remove the import system.dispatcher and you will see that you need to provide an ExecutionContext, which you can lookup from the config, via the system.dispatchers.lookup (I think) fre 29 jan. 2016 kl. 01:42 skrev Ian Nowland : > Hello, > > I'm trying to configure an

Re: [akka-user] Akka cluster sharding exception propagation to the parent actor

BackoffSupervisor has support for that in Akka 2.4.1 /Patrik fre 29 jan. 2016 kl. 00:17 skrev Владимир Морозов : > Hi, > > I have similar problem, my PersistentActor begin restart forever when > inside receiveCommand throws some exception. How I can manage that > restarts?

Re: [akka-user] Trying to configure ActorSystems

So, I've tried replacing the import system.dispatcher with implicit val executionContext = system.dispatchers.lookup("akka.actor.habari-function-scheduler-dispatcher") but I'm still getting the system.dispatcher as the akka.default On Friday, January 29, 2016 at 12:34:28 PM UTC-5, Patrik

Re: [akka-user] StateData mutability in AbstractFSM

Technically it may be safe in that case, you're in an Actor after all. However I'd argue it's bad style as it mixes an API designed for immutable data passing (the data param of FSM), in a mutable way, which can/will lead to confusion when someone else reads your code. If you want to have (or

Re: [akka-user] StateData mutability in AbstractFSM

Hi Konrad, Thanks for the guidance, much appreciated! Good points, will try to stick to immutable data params for FSM. Have a great weekend :) On Friday, January 29, 2016 at 3:40:23 PM UTC-8, Konrad Malawski wrote: > > Technically it may be safe in that case, you're in an Actor after all. >

[akka-user] Delay using Akka Stream Source with PlayFramework 2.5

Hi, In Play 2.5 Akka Stream is the default stream processing library. I don't know if it's a Play or an Akka Stream problem, I'm trying to stream some messages with an Akka Stream Source from a Play controller : def timeline(keyword: String) = Action { val source =

Re: [akka-user] StateData mutability in AbstractFSM

Haha, love it. Will print that out and stick a copy on the side of my monitor to keep me reminded :D On Friday, January 29, 2016 at 5:24:51 PM UTC-8, Konrad Malawski wrote: > > Yup, happy hakking! > > // related, a visualisation of the generalised form of the problem from a > talk I'm about to

Re: [akka-user] StateData mutability in AbstractFSM

Yup, happy hakking! // related, a visualisation of the generalised form of the problem from a talk I'm about to deliver: // https://www.evernote.com/l/AAkD5JPO-rVM3J5S7bnd1g_awyWstD8kCOIB/image.png ;-) --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 30 January 2016 at 09:51:41, James P

[akka-user] Security analysis of Akka

Hi Akka Gurus, Has anybody done security analysis of Akka infrastructure. I am looking at Akka for implementation, but I want to make sure that there are no security holes in Akka implementation. Thanks, -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ:

[akka-user] Re: Dynamic flow multiplexer

I used `SourceQueue` to handle this case: first materialize a graph that takes elements offered to a source queue, then create a sink that consumes elements and publishes them to that source queue: val kafkaSink: Sink[Event, Unit] = //... val kafkaPublisherGraph:

Re: [akka-user] Dynamic flow multiplexer

Hey Viktor, I never thought of using the underlying reactive streams API directly but it sounds like a good idea! cheers, --Jakob On Fri, Jan 29, 2016 at 12:45 AM, Viktor Klang wrote: > Hi Jakob, > > Perhaps create a fanout Publisher from the Sink and materialize the >

Re: [akka-user] Dynamic flow multiplexer

Hi Jakob, Let us know how that solution fares! -- Cheers, √ On Jan 29, 2016 8:10 PM, "Jakob Odersky" wrote: > Hey Viktor, > I never thought of using the underlying reactive streams API directly > but it sounds like a good idea! > > cheers, > --Jakob > > On Fri, Jan 29, 2016

[akka-user] StateData mutability in AbstractFSM

Hi folks, Good day. I'm just starting with Akka (Java with Lambda) and I have a question regarding AbstractFSM. When using "*akka.actor.FSM.State.using(Data)*" does "*Data*" need to be immutable? Example: *when(State.Idle,* * matchEvent(Event.class, StateData.class,* * (event, stateData) ->*

[akka-user] Re: Akka 2.4.1 cluster ShardCoordinator not starting

-> On Fri, 29 Jan 2016 17:40:24 +0100, Patrik Nordwall said: > Note that the leveldb journal can't really be used with Cluster Sharding, > because it is a local only journal. Yes, you can play with it with one > cluster node, > otherwise you need to a distributed

Re: [akka-user] scan and map

Thanks! Sent from my phone - will be brief > On Jan 29, 2016, at 5:25 AM, Endre Varga wrote: > > > >> On Fri, Jan 29, 2016 at 1:21 PM, Martynas Mickevičius >> wrote: >> Hi, >> >> you can do that using scan with something like