[akka-user] Re: Using ActorPublisher without ActorSubscriber

Here is the code for my actor: https://gist.github.com/simao/3003ee256751cfb7b2f7 If i put a log message on `deliverBuf` then I see that this method gets called for each event, but totalDemand is always 0. Thank you for your help. Simao On Wednesday, March 9, 2016 at 10:41:13 PM UTC+1,

[akka-user] Re: Using ActorPublisher without ActorSubscriber

Your actor is supposed to receive ActorPublisherMessage.Request message after the stream is materialized. At this point totalDemand should be > 0 and you are allowed to call onNext Can you show the code of your publisher actor? Cheers, Rafał W dniu środa, 9 marca 2016 13:48:27 UTC+1

[akka-user] Re: [akka java 2.4.2] creating a flow sending elements of the stream to given actorRef and pushing results back to stream

You're welcome! I'm glad you managed to solve this puzzle :) W dniu środa, 9 marca 2016 15:00:06 UTC+1 użytkownik paweł kamiński napisał: > > beware of singletons in spring :] be lazy be prototype ;] > so updater ref for second connection was never created and then ask got > invalid ref or

[akka-user] awaitTermination not working?

Hi group! Thanks for your time in advance. I'm using Java version 2.3.13. In my JUnit tests and when I'm testing in single node the awaitTermination function after the traditional shutdown() is not awaiting for the actor system termination. In fact the actorsystem is not event starting to

Re: [akka-user] akka 2.4.2 java - How to create custom ContentType

I know that this is maybe boring, but can you point me in any direction how to correctly construct akka.http.scaladsl.model.MediaType. applicationWithFixedCharset("my-own", ?, ?) in java? charset I can take from scala enums but the last parameters I have no idea. and can you tell what is the

Re: [akka-user] Re: How to? - Sink.foldM[U, T](zero: U)(f: (U, T) ⇒ Future[U]): Sink[T, Future[U]]

On Wednesday, March 9, 2016 at 1:20:37 PM UTC+3, Giovanni Alberto Caporaletti wrote: > > It would fail with an empty stream. You can use lastOption but you would > need to map over the materialized value thus needing an execution context > outside the stream context. > Oh.. Yes! Thanks for

Re: [akka-user] Akka typed and persistent actors

He surely could. But what's the point of it? Only the PersistentActor will be recovered in case of failure, not the Typed one. Two points which make it worthwhile: - In case of failure a PersistentActor stops. Thus, having it supervised by the Typed one makes sense as we can restart it there

Re: [akka-user] Re: Is akka.http.scaladsl.HttpExt.cachedHostConnectionPoolHttps buggy ?

Thanks for reporting, will have a look into it. Thanks for the reproducer – is it actually usable without having some external settings / account there? Also, please use `ContentTypes` instead of RawHeaders for modeling content types. Ticket is here: https://github.com/akka/akka/issues/19985

[akka-user] Re: [akka java 2.4.2] creating a flow sending elements of the stream to given actorRef and pushing results back to stream

beware of singletons in spring :] be lazy be prototype ;] so updater ref for second connection was never created and then ask got invalid ref or something like that because eventually messages were sent to updater actor but from deadletter :) thanks for help :) On Wednesday, 9 March 2016

[akka-user] Using ActorPublisher without ActorSubscriber

Hello, I think I misunderstand the usage of ActorPublisher. I read the documentation (http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0.3/scala/stream-integrations.html#ActorPublisher) but I cannot seem to understand how to use it. I am creating an ActorPublisher actor and

Re: [akka-user] Re: How to? - Sink.foldM[U, T](zero: U)(f: (U, T) ⇒ Future[U]): Sink[T, Future[U]]

It would fail with an empty stream. You can use lastOption but you would need to map over the materialized value thus needing an execution context outside the stream context. cheers G On Wednesday, 9 March 2016 01:19:01 UTC+1, Andrew Gaydenko wrote: > > Giovanni, I mean your last suggestion

[akka-user] Re: [akka-http-2.4.2] connection timeouts under load

I have very little time but I'll try to create a simple reproducer app and open an issue (if that's the case) asap On Wednesday, 9 March 2016 01:28:57 UTC+1, David Knapp wrote: > > For what it's worth I've been occasionally seeing something similar, but > it's extremely intermittent and hard to

Re: [akka-user] akka 2.4.2 java - How to create custom ContentType

Thanks, will look into it soon! --  Cheers, Konrad 'ktoso’ Malawski Akka @ Lightbend On 8 March 2016 at 22:42:30, paweł kamiński (kami...@gmail.com) wrote: @Konrad https://github.com/akka/akka/issues/19976 created, hope it will help I need a hint how to create empty scala.collection.Seq in

[akka-user] Re: Akka HTTP Websockets Java with Actor

*Disclaimer:* The Akka HTTP performance on that page is outdated, now; if Akka HTTP is around 75% performance of Play 2, you can guess where it would be on that list. On Wednesday, March 9, 2016 at 9:58:04 AM UTC, Guido Medina wrote: > > Hi Alan, > > I hope the Akka/Java example has helped, I

Re: [akka-user] Akka cluster: Passivation + reshard

Ok. I've tried to find it out in the group without success. Many thanks for your time! On Wed, Mar 9, 2016 at 10:36 AM, Patrik Nordwall wrote: > I think this has been answered elsewhere, but anyway. Passivation of all > entities does not mean that the shard goes

Re: [akka-user] DistributedPubSub -- list of topics

On Fri, Feb 26, 2016 at 6:08 PM, Val P wrote: > Thanks, I found the GetTopics in the code eventually, and I can match > wildcards on it. > > I did notice that topics hang around quite a bit, which means if I get > topics, I may be publishing to topics that are no longer

Re: [akka-user] Open-Source Monitoring Tool - Akka 2.4.2

Our http://resources.typesafe.com/monitoring/docs/ monitoring has seen an internal release of supporting 2.4.2 already. You can get access to it via getting a sub:  http://www.lightbend.com/services/expert-support via this form: https://www.lightbend.com/company/contact Hope this helps. I'm not

[akka-user] Open-Source Monitoring Tool - Akka 2.4.2

Hey, Our team is working with Akka v2.4.2, and I couldn't find any monitoring tool that supports this version. Is there such a thing already or is it too early? Thanks, Gilad -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>