[akka-user] Re: akka streams with http - downstream error propagation without collapsing the stream

Hi Leslie, Did you ever find a nice pattern for this? I ask because I'm doing something very similar and am currently unhappy with the error handling capabilities of Akka streams... On Monday, July 13, 2015 at 9:50:10 AM UTC-4, leslie...@googlemail.com wrote: > > I've tried to implement a

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

When you say database could it be you mean an SQL database? Because for those Slick 3 (also known as Reactive Slick) exposes queries as reactive streams so you can directly consume them using Akka Streams (Source.fromPublisher(myquery...)) -- Konrad `ktoso` Malawski Akka @

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

Hi Devin, It might even be possible to do that using the flow api combinators, something like this: implicit val system = ActorSystem() implicit val mat = ActorMaterializer() def fetchFromDatabase(position: Int): Vector[Int] = (position to (position + 99)).toVector val periodicFetch:

Re: [akka-user] AKKA supervision java lambd

The exception thrown when the actor you have created does not have any receive-logic defined, even if it is a supervisor it must have some logic defined for when a message is sent to it. If you have no protocol to interact with the supervisor actor you can set an empty behavior like this in the

Re: [akka-user] Akka Cluster - can RemoteRouterConfig use dynamic list of remote Addresses?

Hi Regu, You can either use a group, in which case you are responsible for starting the routee on every node (note that you can also limit which nodes that have routees by means of the use-role configuration), or you can use a pool where the router will create routees on the cluster nodes. With

Re: [akka-user] lib and src directory missing from akka_2.11-2.4.6.zip

Hi Adam, It seems to be a regression in our build/release scripts, thanks for notifying us about it, we'll look into it. (Ticket if you want to follow what is going on: https://github.com/akka/akka/issues/20661) -- Johan Akka Team Typesafe - Reactive apps on the JVM Blog: letitcrash.com

Re: [akka-user] Spring Scheduler with AKKA: connot create children while terminating or terminated

That error is thrown if you try to create actors in a terminated actor system, probably because you are somehow re-using the original actor system after it has terminated.​ -- Johan -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] LoggerInitializationException - Akka logger timing out in Play application

Take a look here: https://www.playframework.com/documentation/2.4.x/JavaAkka#Configuration On Mon, May 30, 2016 at 2:41 PM, Akka Team wrote: > The reference.conf contains default configuration for Akka, it is nothing > you need to add or change, it is shipped together

Re: [akka-user] Re: Proper way to shut down an outgoing http request stream?

The singleRequest method will use an internal connection pool, the warning is probably from a lingering connection in the pool when you terminate the system, so the warning is harmless. If you want to gracefully terminate the pool you can use Http.shutdownAllConnectionPools() and then not

Re: [akka-user] Bug in akka.http.javadsl.server.directives.WebSocketDirectives?

This seems to be an oversight in the API, please file a ticket (and if possible a PR) about it. The materialized type should be Any (Object seen from the Java side) as it is not really passed on anywhere or consumed by anything. -- Johan Akka Team Typesafe - Reactive apps on the JVM Blog:

Re: [akka-user] [2.4.6] ClassLoader problem when running tests in SBT

We use Scalatest, but Specs2 should work fine as well. There is most likely something special in your project setup or tests. For example it could be that you run the tests non-forked and keep a reference to the DefaultLoggingFilter in an object that lives across test runs. -- Johan On Sun, May

Re: [akka-user] LoggerInitializationException - Akka logger timing out in Play application

The reference.conf contains default configuration for Akka, it is nothing you need to add or change, it is shipped together with the classes in the akka-actor artifact. Your IDE should let you look at the contents of dependencies, it will be in the root directory of the akka-actor jar-file. On

Re: [akka-user] LoggerInitializationException - Akka logger timing out in Play application

I am using Akka in Play 2.4.6 application and could not find reference.conf in my play application. Also, there is no reference available in Play or Akka docs how I can add it in Play application. Can you please share this info? Thanks, Suraj -- >> Read the docs:

Re: [akka-user] LoggerInitializationException - Akka logger timing out in Play application

You didn't change the timeout value. On Mon, May 30, 2016 at 1:16 PM, Suraj Mundada wrote: > I am still getting the timeout exception and every time I have to restart > my prod server to fix the issue. > > I also tried following: > > akka { > > loggers =