Re: [akka-user] How do you determine/set the version of Akka used by the Scala REPL?

Check the classpath -- Cheers, √ On Apr 7, 2016 05:12, "Mark Bower" wrote: > Thank you, Victor! > > Where does the Scala REPL get it's Akka version, and how can that version > be changed? I tried "System.getProperty("config.path")", but that returned > "null" (?). > >

[akka-user] Akka Persistence: Where do the execution of the Command Goes when it is not simply a state update

Just for clarification: Where do the execution of a command goes, when the execution is not simply a state update (like in most examples found online) For instance, in my case, - The *Command* is *FetchLastHistoryChangeSet* which consist in fetching the last history changeset

Re: [akka-user] How do you determine/set the version of Akka used by the Scala REPL?

Thank you, Victor! Where does the Scala REPL get it's Akka version, and how can that version be changed? I tried "System.getProperty("config.path")", but that returned "null" (?). Mark On Wed, Apr 6, 2016 at 3:00 AM, Viktor Klang wrote: > ActorSystem.Version > > On

[akka-user] Re: Dedicated seed nodes for akka cluster

This looks interesting, has any work been done to use consul kv by any chance? Does this solution avoid the split brain? On Thursday, March 17, 2016 at 8:32:50 PM UTC-4, Rafał Krzewski wrote: > > There are ways to boot up Akka cluster without dedicated seed node: > whichever node comes up

Re: [akka-user] Re: Dedicated seed nodes for akka cluster

Is there a recommendation (beyond using the split brain resolver which looks like you need a subscription?) for manual downing or managing split brain? On Saturday, April 2, 2016 at 9:45:10 AM UTC-4, Patrik Nordwall wrote: > > If you use auto-downing and that triggers because of a network

[akka-user] Distributed Data and Akka Cluster Sharding

I am using Cluster Sharding with the Distributed Data Module. I have remember entities on so that I can auto-start an entity during failover. Even with the distributed data module, it appears as though I _need_ to have an akka persistence journal or else my Actor system doesn't start. Is

[akka-user] Re: Akka Cluster without Remoting?

To close the loop on this, here's what I ended up doing. Originally, a node would either start a Master actor system or a Worker actor system, depending on startup flags. (Again, Master would not communicate with Worker or vice versa through messages; each node was self-contained.) After

Re: [akka-user] Akka Streams Remote Materialization

Hi all, any news concerning this request? Cheers On Thursday, 28 May 2015 11:16:36 UTC+2, Oliver Winks wrote: > > Thanks for the info. I'm looking forward to future releases of Akka > Streams. > Cheers > > On Wednesday, 27 May 2015 22:24:44 UTC+1, Akka Team wrote: >> >> Hi Oliver, >> we do

[akka-user] Is there a way to look in an inbox?

Currently I have a process that is set up as follows: 1. Pulse every minute and see if a domain object should be changed, 1. If not then do nothing. 2. If there is an object that needs to be processed, find all child objects remaining to process. 1. If this is

Re: [akka-user] Aborting tcp connection in Akka 2.4.3 with Http().singleRequest()

OK, thanks. I've found the reason why my requests never come back. Even though the server responses 404, I have to consume the response body. Or the pooled connections will never get released. On Wednesday, April 6, 2016 at 6:19:44 PM UTC+8, Konrad Malawski wrote: > > Firstly, it's a DEBUG

Re: [akka-user] [akka-streams] Resource pool for use within a flow

Hi John, You could hide step 2-4 behind a method returning a future, that way you can run the blocking operations on a separate threadpool. Pseudocode: def doWorkWithResource(item: WorkItem): Future[ComputationResult] = { Future { // acquire resource // do work // return resource

Re: [akka-user] Routing Kafka messages to websocket

Hi Vish, There currently is no stage in Akka Stream that will allow you to dynamically add and remove listeners, we have some ideas but nothing implemented or planned yet (see ticket https://github.com/akka/akka/issues/19478). So you would have to implement your own stage for this. The

Re: [akka-user] Behavior of akka 2.4.3 with modeled custom headers

Hi Chris, This seems like a regression bug, please file a ticket thanks! On Tue, Apr 5, 2016 at 7:46 PM, Chris Baxter wrote: > So I have some custom modeled headers, with one of them being defined like > so: > > object `X-Access-Token` extends >

Re: [akka-user] Aborting tcp connection in Akka 2.4.3 with Http().singleRequest()

Firstly, it's a DEBUG level message – it's nothing "bad" happening. Simply after some time of no data being passed through a connection is is being shut down – it's an "idle timeout", otherwise we may end up having thousands of connections open which are doing nothing. Please read the docs on

[akka-user] Aborting tcp connection in Akka 2.4.3 with Http().singleRequest()

hi, I use `Http().singleRequest()` to contact with a upstream API server, and the server returns 404 all the time (when query non exists entities). And suddenly, roughly about 3 ~ 4 round request-response trips, I get such log with stack trace not formatted. And after this log, my requests

Re: [akka-user] How do you determine/set the version of Akka used by the Scala REPL?

ActorSystem.Version On Wed, Apr 6, 2016 at 6:04 AM, Mark Bower wrote: > I am running MacOSX10.8, Java1.8, Scala 2.11 and would like to run Akka > 2.4 in the Scala REPL, but I cannot find out how to specific where the > Scala REPL gets its Akka implementation. I can run