Re: [akka-user] Alpakka SSE recovery

Thanks. That looks definitely like a bug. Could you please open an issue against Alpakka? Cheers Heiko > Am 03.07.2017 um 16:35 schrieb Bayarmunkh Davaadorj : > > Hi, > > Here are 3 scenarios I tested. > > 1. The server is unavailable, the client starts - the client is

Re: [akka-user] Alpakka SSE recovery

It should just work. If not, it’s a bug. Could you please create a simple reproducer? Thanks Heiko -- Heiko Seeberger Home: heikoseeberger.de Twitter: @hseeberger Public key: keybase.io/hseeberger > Am 03.07.2017 um 07:52 schrieb Bayarmunkh Davaadorj : > > > Hi, > > I'm

Re: [akka-user] How to create an Actor System Integration test with TestProbes?

You could parameterize the (parent) actors with a function which creates child actors (and returns refs). For "normal mode” provide a function that creates the actual child actors, for testing inject a TestProbe.ref. Alternatively you can achieve the same with a protected factory method for

Re: [akka-user] Considerations when pushing millions of messages through DistributedPubSub?

I think with 100.000 msg/sec you are going to overload Akka Remote. You might want to consider accumulating events thereby reducing the frequency. Heiko -- Heiko Seeberger Home: heikoseeberger.de Twitter: @hseeberger Public key:

Re: [akka-user] How do I get connected Inlet and Outlet ? Akka 2.4.6

> On 25 May 2016, at 00:33, Jack Daniels wrote: > > Could you please explain meaning of `maximumBurst` parameter with example? If you throttle to a certain rate, `maximumBurst` defines what should happen if fewer elements have arrived from upstream for some time (your

Re: [akka-user] ANNOUNCE: New Remoting Milestone 1

Great stuff! Very very exciting times ahead! Cheers Heiko -- Heiko Seeberger Home: heikoseeberger.de Twitter: @hseeberger Public key: keybase.io/hseeberger > On 20 May 2016, at 16:28, Patrik Nordwall

Re: [akka-user] Mock framework for Akka actors

Take a look at Akka akka-testkit’s `TestProbe` and its auto pilot stuff. Heiko -- Heiko Seeberger Home: heikoseeberger.de Twitter: @hseeberger Public key: keybase.io/hseeberger > On 11 May 2016, at

Re: [akka-user] Spray-json support and FromResponseUnmarshaller

> On 22 Apr 2016, at 12:11, Edmondo Porcu > wrote: > > Shouldn't be possible to lift the unmarshaller with an implicit conversion? How? Do you want to block? Heiko -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ:

Re: [akka-user] Spray-json support and FromResponseUnmarshaller

Edmondo, You can’t expect unmarshalling to magically unfold the Future you get back. Hence you have to map. Or, to be more precise, you have to flatMap, because unmarshalling returns another Future. ``` responseFuture.flatMap(Unmarshal(_).to[MyClass]) // Notice that you’re still in Future

Re: [akka-user] [akka-http] How to create custom Content-Type?

Here’s an example: https://github.com/hseeberger/akka-sse/blob/master/akka-sse/src/main/scala/de/heikoseeberger/akkasse/MediaTypes.scala#L30 -- Heiko Seeberger Home:

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

There is Consul support for ConstructR, for details please join the ConstructR channel on Gitter. ConstructR is for bootstrapping an Akka cluster, not for dealing with downing of unreachable nodes. Well, it could help with that as a side-effect, because by default if a node can’t refresh

Re: [akka-user] Distributed Data and Akka Cluster Sharding

Have you **configured** Cluster Sharding to use Distributed Data? Could you paste your configuration? Cheers Heiko -- Heiko Seeberger Home: heikoseeberger.de Twitter: @hseeberger Public key: keybase.io/hseeberger

Re: [akka-user] Slf4j Akka adapter

Wrt inclusion in Akka: I don’t want to use SLF4J/Lockback, but Log4j 2! -- Heiko Seeberger Home: heikoseeberger.de Twitter: @hseeberger Public key: keybase.io/hseeberger > On 31 Mar 2016, at 12:43, Patrik

Re: [akka-user] Await#result (T) versus Future[T]

> On 30 Mar 2016, at 20:04, Kevin Meredith wrote: > > Hi Johan - > > Thanks for this helpful reply. I've re-read it a few times. > > The following is my incomplete understanding, followed by my questions. > > >A typical spray web service uses a single actor. It