Re: [akka-user] how to enable secure tcp socket connection on server side in Akka

The library you’re looking for is Akka Streams, not bare Akka IO. Coming from Mina you might want to read http://doc.akka.io/docs/akka/2.4/java/stream/stream-composition.html about how protocol pipelines are expressed. Unfo

Re: [akka-user] how to enable secure tcp socket connection on server side in Akka

Thanks for you reply. I'm new in akka. I didn't get how to enable secure tcp chat server, while binding. Can you plz give some example code... Tcp.get(getContext().system()).manager().tell(TcpMessage.bind(getSelf(), inetSocketAddress, 100), getSelf()); On Thursday, 29 September 2016 17:01:47 U

Re: [akka-user] Re: What's the replacement for Akka Actor Publisher and Subscriber?

I think you're missing the important word here: they can't be used with *remote* actors. As I understand it, the point is that you can't just connect it to any old Actor, which might be on some other node -- you can only do it with *local* Actors... On Wed, Sep 28, 2016 at 11:50 PM, Dagny T wrot

[akka-user] Successor Technology to Microkernal

I read that the Microkernal was going away. Would you tell me, if you can: - The name of the successor technology. - A link to doc on it - Will new technology be able to put anything found in Akka with Scala in one package? - Any idea when it will roll out? - When will Microkernal be removed?

Re: [akka-user] Understanding akka.http.server.max-connections

Thank you! On Thursday, September 29, 2016 at 10:40:43 AM UTC-7, Konrad Malawski wrote: > > Number of open connections. > Not websockets, but connections in general, AFAIR. > > On 29 Sep 2016 7:38 p.m., "Federico Nusymowicz" > wrote: > > My websocket server will maintain many (mostly idle) connec

[akka-user] akka shutdown pattern

Hi, Im working on an play app that sends message to akka actors. In our env, continues deploy happens multiple times a day where severs go down for deploying. Question: How do I make sure that all the messages being processed before restart/shutdown the play application? Do I have to use at-l

Re: [akka-user] Understanding akka.http.server.max-connections

Number of open connections. Not websockets, but connections in general, AFAIR. On 29 Sep 2016 7:38 p.m., "Federico Nusymowicz" wrote: My websocket server will maintain many (mostly idle) connections. Does `akka.http.server.max-connections` place a limit on the number of open websockets? Or is

[akka-user] Understanding akka.http.server.max-connections

My websocket server will maintain many (mostly idle) connections. Does `akka.http.server.max-connections` place a limit on the number of open websockets? Or is `akka.http.server.max-connections` a limit on the number of websockets that can be opened concurrently? -- >> Read the

[akka-user] Re: Message not delivered log entry, after log entry of message having been delivered?

On Wednesday, September 28, 2016 at 1:55:42 PM UTC-7, que...@gmail.com wrote: > > I have one actor that sends a message to another actor. There is a message > logged that the message is sent and a message logged that it was received, > then later there is a message saying that the message could

[akka-user] Re: [akka-stream] How to implement Spark's cogroup/join operation

I'm trying to figure out why this is hanging/idling indefinitely : Source.fromIterator(() => Iterator.from(0).take(500).map(_ -> 1)) .groupBy(Int.MaxValue, _._1) .mergeSubstreamsWithParallelism(256) .runWith(Sink.seq) This is the only way how to avoid instantiating ridiculous amounts of su

[akka-user] Re: Beginner questions

I think for "*2\ Can actors have states ?*" the documentation is clear enough : > One actor, which is to oversee a certain function in the program might > want to split up its task into smaller, more manageable pieces. For this > purpose it starts child actors which it supervises ... The q

[akka-user] Re: Problem detecting Websocket failure

source .viaMat( Http().webSocketClientFlow( WebSocketRequest( host + "/console") ) )(Keep.both) .alsoTo(Sink.onComplete(_ => { self ! RestartWebsocket })) .toMat(sink)(Keep.left) .run() -- >> Read the docs: http://akka.io/docs/ >>

[akka-user] Beginner questions

Hi There, I have a (Java) application that collect information form various sources (SCM, Execution envs, Issues tracker, ..) with the goal of identifying " *violations*" on our *products* (New component found, New dependency found, No sources for project, Wrong name, ..) and publish them as eve

Re: [akka-user] how to enable secure tcp socket connection on server side in Akka

Please refer to the documentation: http://doc.akka.io/docs/akka/2.4.10/java/http/server-side-https-support.html#ssl-config-java It has a nice search box which you can use to search for "SSL". -- Konrad `ktoso` Malawski Akka @ Lightbend On 29 September 201

[akka-user] Akka streams in web application

Hi, I am planning to use Akka Streams in web application. Below is my use case. Whenever the request come to web server, I will do some operations like stg01, stg02 ... *I have a below questions :- * - Do we need to close the streams after each request processed ? - If N multiple request

[akka-user] how to enable secure tcp socket connection on server side in Akka

In Mina Simply I have added by this. private static void addSSLSupport(DefaultIoFilterChainBuilder chain) throws Exception { SslFilter sslFilter = new SslFilter(new SSLContextGenerator().getSslContext()); chain.addFirst("sslFilter", sslFilter); } Can anyone let me know how to add ssl

Re: [akka-user] Memory Bounding Akka Streams

On Thu, Sep 29, 2016 at 1:41 AM, Dagny Taggart wrote: > > > LATEST updated understanding I have then is the following; and if someone > could PLEASE correct my (Newbie) understanding with a link to a clear Blog > Post or GitHub repo illustrating the concept! > > 1) The Akka Stream Graph DSL API's

Re: [akka-user] Memory Bounding Akka Streams

2016-09-29 1:41 GMT+02:00 Dagny Taggart : > > > LATEST updated understanding I have then is the following; and if someone > could PLEASE correct my (Newbie) understanding with a link to a clear Blog > Post or GitHub repo illustrating the concept! > > 1) The Akka Stream Graph DSL API's abstraction-