[akka-user] Re: Akka Backed Micro Service Framework - BeyondJ

thank you for share this:) 在 2016年3月9日星期三 UTC+8上午5:33:17，nkasvosve写道： > > So Lightbend is about to release Lagom ... we have already built a robhust > framework based on Akka. > > http://beyondj.com > > BeyondJ is a JVM platform for deploying wars and fat jars. It provides, > out of the box,

[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

thanks, for all help. it is running for ever as I am testing concepts of updating a remote client asynchronously, in real time Updater will get updates from other actors and yes I will add supervision strategies. Im running this app from unit tests that creates spring context and also

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

Giovanni, I mean your last suggestion with custom stage. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.com/group/akka-user ---

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

Giovanni, hi! What do you think about replacing val sink = Sink.fold(zero)(Keep.right[U, U]) with val sink = Sink.last[U] ? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html

[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

but this is impossible to change concurrently as I log it and then pass to Pattern#ask. I just wonder why it is send from *akka://akka-system/deadLetters* and why *ReceiveTimeout* is not sent back to Updater... the application I try to put together is a proof of concept and there is no use to

[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

First, let me say that even tough I program in Java for a living, I have only ever used Akka with Scala. I'm actually surprised by the amount of syntactic noise in Akka with Java variant! I doubt the "*ask* sends messages to only one updater even though I use right actorRef" part: 2016-03-08

[akka-user] Akka Backed Micro Service Framework - BeyondJ

So Lightbend is about to release Lagom ... we have already built a robhust framework based on Akka. http://beyondj.com BeyondJ is a JVM platform for deploying wars and fat jars. It provides, out of the box, clustering, load balancing, scaling, and self healing. No split brain problems. One

Re: [akka-user] change of Tech Lead

Dear Roland, Reacting to opportunities – should we add opportunistic as another trait to Reactive? My apologies, but this was just too tempting. When we meet in Munich, I owe you a beer for this and another one or as many as you can drink for the fantastic work you did for Akka. Dear Patrik,

[akka-user] Re: change of Tech Lead

Congrats Roland! On Monday, March 7, 2016 at 10:42:32 AM UTC-7, rkuhn wrote: > > Dear fellow hakkers, > > as of today I am passing on the baton of Akka Tech Lead @ Lightbend to > Patrik Nordwall. Don’t worry, I will stay around and keep working on Akka, > but it will no longer be my day job

[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

one more thing that is not working for me right now this is a code handling incoming connection and requests receive(ReceiveBuilder .match(IncomingConnection.class, connection -> { log.info("Established new connection from {}.", connection.remoteAddress());

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

OK, thanks, any hints how to work this around? I ll create an issue. On Tuesday, 8 March 2016 17:37:48 UTC+1, Konrad Malawski wrote: > > Seems we might be missing some factory methods on the MediaTypes trait, > the scaladsl has methods for returning more specific types, such as >

Re: [akka-user] akka-http proxy support

Hi Konrad, thanks for the quick answer. Fortunately it is only a small part of our code that needs that. I will use Apache HttpClient for now, which does everything we need. Best regards, Michael On Tuesday, March 8, 2016 at 5:37:01 PM UTC+1, Konrad Malawski wrote: > > Correct, HTTPS Proxies

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

Seems we might be missing some factory methods on the MediaTypes trait,  the scaladsl has methods for returning more specific types, such as `applicationWithCharset` etc. Would you please open a ticket about "feature parity of creating MediaTypes for JavaDSL"? Thanks in advance! Please note

Re: [akka-user] akka-http proxy support

Correct, HTTPS Proxies are not supported yet, see ticket:  https://github.com/akka/akka/issues/16153 Sadly we're not sure when we'll get the chance to work on this yet. For the time being you may want to try Play's WS library, though I'm not sure if they support this feature hm... (They're

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

I try to force my http server (using only http-core) to respond with headers. I get from request Accept header String mime = request.getHeader(Accept.class) .map(HttpHeader::value) .orElse("application/json"); but then it is not clear to me how to create custom Content-Type

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

Here is an adaptation of the Scala sample, but in Java: import akka.NotUsed; import akka.actor.*; import akka.http.javadsl.model.ws.Message; import akka.http.javadsl.model.ws.TextMessage; import akka.http.javadsl.server.HttpApp; import akka.http.javadsl.server.Route; import

[akka-user] akka-http proxy support

Hi, we need to access a REST interface using HTTPS which is behind a proxy. The akka-http documentation states that proxy support for HTTPS connections is currently unsupported. Is there any way to use a HTTPS proxy with akka-http? If not, can someone recommend a good (Java) https client

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

It also may be helpful to check this blog post http://blog.scalac.io/2015/07/30/websockets-server-with-akka-http.html and its source code https://github.com/ScalaConsultants/wsug-akka-websockets On Tuesday, February 23, 2016 at 3:33:18 PM UTC+3, Guido Medina wrote: > > Hi, > > Has anyone been

[akka-user] Android chat

Hi all, I am using Akka to create a chat application. I start the TCP socket using StartTcpConnectionActor and after a new connnetion is established I start the TcpConnectionActor for each connnection. My android client, uses the Socket class to connect to the server and everything works ok.

Re: [akka-user] An equivalent of ReactiveX `PublishSubject` in akka-streams

Hi Johan, Thanks a lot for the reply and for sharing this information! It is good to know that you already discussed this. Looking forward to progress in this direction. What I ended up doing is I created an `ActorPublisher` and then I subscribe to it like this: val eventStore =

[akka-user] Re: change of Tech Lead

best wishes for all:) -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.com/group/akka-user --- You received this message because

[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

ok, I was playing around with this yest. there is no way to do that. only mapAsync is a way to create a flow that pushes elements of the stream to 3rd party components such as actors. this is a bit confusing as there is a ActorPublisher that would be good fit here if only Flow had a construct

[akka-user] Re: change of Tech Lead

Roland, Thanks for your help here, in the group! - for some magic reason you are just the best in understanding my ugly, vague questions. Good luck! -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

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

I'll volunteer to review :) On Tue, Mar 8, 2016 at 12:26 PM, Konrad Malawski wrote: > Here's the ticket, you'd like to contribute these operations (it's pretty > easy to contribute, one can look at mapAsync and see how it differs from > map): >

Re: [akka-user] change of Tech Lead

Congratulations to both of you, good luck with your new adventure Roland. On 7 March 2016 at 17:37, Roland Kuhn wrote: > Dear fellow hakkers, > > as of today I am passing on the baton of Akka Tech Lead @ Lightbend to > Patrik Nordwall. Don’t worry, I will stay around and keep

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

I'd like to repeat that a scanAsync and a foldAsync would be very welcome additions :) On Tue, Mar 8, 2016 at 12:01 AM, Andrew Gaydenko wrote: > Giovanni, hi! > > Thanks! - have played with this test. In fact, I started tests with > -Xmx=128M, and range up to 20M. The

Re: [akka-user] An equivalent of ReactiveX `PublishSubject` in akka-streams

Hi Oleg, You are right that "Subscriber" is very low level (and "Processor" is as well) and hard to get right, it is meant for libraries to implement for interop rather than end user implementations. There isn't any component that supports dynamic subscription in akka-streams, so that is why you

Re: [akka-user] Re: Akka.NET or Alternative

Ah, this reminds me: together with the core Orleans developers I did a comparison of the two approaches, take a look at https://github.com/akka/akka-meta/blob/master/ComparisonWithOrleans.md for in-depth information.

Re: [akka-user] change of Tech Lead

> 8 mar 2016 kl. 11:03 skrev Rafał Krzewski : > > Twitter, very soon: "They told him to work on this new enterprise Java > framework, so he flipped his s* and left! Death of Scala AND Akka imminent! > Let's run around flailing our arms in panic!" No, I don’t think

Re: [akka-user] Akka.NET or Alternative

Here's an analysis of Orleans I wrote when it was announced. On Tuesday, March 8, 2016 at 1:08:25 AM UTC, Andy Czerwonka wrote: > > Thanks Vitor - Orleans looks promising. > > On Monday, March 7, 2016 at 2:29:43 PM UTC-7,

[akka-user] Re: Akka.NET or Alternative

One thing to remember with Orleans - it makes completely different guarantees than Akka. Where Akka and Erlang focus on the lowest possible costs so that you choose when to pay them, Orleans loads them in up front. That can make it easier on developers, but likely not as efficient. Good

[akka-user] Re: change of Tech Lead

Twitter, very soon: "They told him to work on this new enterprise Java framework, so he flipped his s* and left! Death of Scala AND Akka imminent! Let's run around flailing our arms in panic!" Seriously though, many thanks to Roland and best of luck with the new job! Cheers, Rafał W dniu

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

Hi Guido, this post helped me allot. Thanks. How can I send message from the Actor to the "connected" websocket? As a response to initial message received from websocket and as a standalone/push message from Actor to websocket? Thank you in advance. Br, Alan Dana srijeda, 24. veljače 2016. u