[akka-user] Re: How to send a message in a reactive stream from the Sink to the Source in a web socket connection

Final solution is as simple as beautiful (and was answered on Stackoverflow ): Flow.fromSinkAndSourceMat(metricsSink, metricsSource, (sinkActor, sourceActor) -> {

[akka-user] Re: akka2.3: cannot change log pattern inside actor

This post was sent incautiously ... anyway the problem is actor.event.logging never pick up the logback.xml I have initialized the ActorSystem via val system = ActorSystem("root", ConfigFactory.load) 在 2016年5月24日星期二 UTC+8上午1:54:25，xsy...@gmail.com写道： > > I am using akka 2.3.15 with maven,

[akka-user] akka2.3: cannot change log pattern inside actor

I am using akka 2.3.15 with maven, akka-slf4j and logback The logs inside actor receive method is working, but the logging pattern never changes no matter how I change the logback.xml Log inside actor: [INFO] [05/24/2016 01:39:48.803] [Main-akka.actor.default-dispatcher-3]

Re: [akka-user] Akka Cluster + EC2, life cycle of seed node

It seems to me that is smart enough after some testing, but the Akka documentation suggests to use joinSeedNodes in a different manner: "You may also use Cluster(system).joinSeedNodes to join programmatically, which is attractive when dynamically discovering other nodes at startup by using

[akka-user] How to properly use an ActorPublisher that fetches from a database?

Hello all, I'm fairly new to Akka but I've been enjoying it so far. I'm building a simple example service that fetches data from a database periodically and then uses an ActorPublisher to publish the data. Everything works well the first going around but once the first result set is

Re: [akka-user] Akka-Http with Jackson confusion over proper usage of completeWithFutureResponse

Thanks for trying the new JavaDSL and reporting the issue Daniel! I sadly have to confirm it's a mistake in the DSL, completeWithFuture should take Marshaller[T, RequestEntity]. I've logged an issue and submitted a PR to fix it right away:  https://github.com/akka/akka/issues/20592 We'll ship

[akka-user] Akka-Http with Jackson confusion over proper usage of completeWithFutureResponse

Hi All, Hopefully a quick one asking for some advice/pointers on how to marshal and complete a HTTP route using CompletionStage. I've taken a look through the latest v2.5.6 documentation inc. The PetClinic example. What I am trying to do is very similar - marshalling a response from a high level

Re: [akka-user] Re: Implementing ACID style processing using Akka?

Yes, indeed, thanks a lot for writing that up! Sent from my iPhone > On 23 May 2016, at 06:47, Ryan Tanner wrote: > > Great post Matthew! > >> On Sunday, May 22, 2016 at 4:51:39 PM UTC-6, Matthew Howard wrote: >> ugh double-post... I left out the Pat Helland link >>

Re: [akka-user] AsyncWriteJournal - question about asyncWriteMessages

Hi, thanks for your the clarification. Best, Maciej W dniu niedziela, 22 maja 2016 09:46:28 UTC+2 użytkownik rkuhn napisał: > > > > Sent from my iPhone > > On 21 May 2016, at 23:05, Maciej Ciołek > wrote: > > Hello, > I would like to ask about the docs in