[akka-user] Re: akka http dealing with chunked content while already inside an existing stream

I worked towards option 2. Making a nested Source[Source[_]] (I miss using scala). This works, but I get a deadletter which I am unsure what is causing it. Would appreciate to get some feedback if I am heading to correct path, or am I going to have a painful path and might as well shoot my

[akka-user] akka http dealing with chunked content while already inside an existing stream

Hi, I have been trying to use akka streams to process our Kafka based micro service. One micro service would get further data from an older REST based service. I have put in some Java code below (sorry not doing Scala for this code base, as I am working with another developer that would make

[akka-user] Re: Tcp TLS example with client auth

Hello Magnus This is not an answer to your problem but I am trying to get an answer to my problem. I am working on a POC developing a TCP server which listens on device traffic. I was able to implement the server using Akka IO (v2.3.14) and trying to figure out how to configure TLS for this

[akka-user] Re: Unit test akka persistence against the inmem journal

This could be helpful: https://github.com/pawelkaczor/akka-ddd/blob/master/akka-ddd-test/src/test/scala/pl/newicom//test/dummy/DummyOfficeSpec.scala -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] How to disable TLSv1 when I configure "akka.remote.netty.ssl.security.protocol" property as TLSv1.2.

You can set the "jdk.tls.client.protocols" system property to set options for the JVM -- this is a feature that is only available in JDK 1.8 though. https://docs.oracle.com/javase/8/docs/technotes/guides/security/SunProviders.html#SunJSSE_Protocols Otherwise, you would have to set the security

Re: [akka-user] High-level Server-Side API Minimal Example not working

Hi there, I just copy pasted the file and have to say "it works here". Are you sure you have dependencies for akka-http-experimental in your build? It works since ContentTypes is part of the akka.http.scaladsl.model package, and that we've imported all the symbols from at the top of the file:

[akka-user] Type mismatch, expected: ToResponseMarshallable, actual: WebServer.Item

The following example at http://doc.akka.io/docs/akka/2.4/scala/http/common/json-support.html gives an error at line no. 43 and 44. Error:(43, 41) type mismatch; found : WebServer.Item required: akka.http.scaladsl.marshalling.ToResponseMarshallable case Some(item) =>

Re: [akka-user] Passivate Persistent Cluster Singleton

Good idea. Thanks! Best wishes, Siva on 6+ > On Jul 22, 2016, at 3:28 AM, Akka Team wrote: > > Hi Siva, > > I don't recall cluster singleton having a passivation feature. I think this > feature simply does not exists. On the other hand there is not much reason to >

[akka-user] getting out of memory - not able to create new native threads in akka java

Hi, In our system we have a few blocking actors(service calls) and we were using default dispatcher, but when we increase load the system becomes very slow and we observed that the message waits a long time to reach to next actor (which means dispatcher is taking time to transfer messages)

[akka-user] Cleanup after HttpResponse

Hello, I was wondering what is the best way to clean up resources after an HttpResponse was sent over the network. I need to use a legacy file-backed implementation of a buffer to get the data for HTTP responses. The API gives an InputStream to the data and eventually I need to call the

[akka-user] Akka TCP with Actors vs Akka Streams and Flows/Graphs

Has some developed an akka stream based TCP server where connections is kept open and frame delimited messages is pouring in, and is eventually stored somewhere in a database? It seems to be such a simple pattern that i am surprised to not find any examples for it. But maybe the world is not so

[akka-user] How to disable TLSv1 when I configure "akka.remote.netty.ssl.security.protocol" property as TLSv1.2.

Configure file as follow: # Protocol to use for SSL encryption, choose from: # Java 6 & 7: # 'SSLv3', 'TLSv1' # Java 7: # 'TLSv1.1', 'TLSv1.2' protocol = "TLSv1.2" When I use nmap to scan, I find that TLSv1 is enabled: D:\softwares\nmap-7.12>nmap -p --script=ssl* x.x.x.x