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

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

[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?

[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: [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

[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

[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

[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

[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

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

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

[akka-user] Re: DDD/CQRS - Modifying write model solely to support read model projection

Yes, indeed. I think this question is more suited to the DDD/CQRS group. I posted a reaction there. Cheers On Tuesday, 27 September 2016 22:31:37 UTC+2, rrodseth wrote: > > I asked this over on the DDD/CQRS list, but didn't get a reply, so I > thought I'd try here. > > Imagine a system to