Re: [akka-user] AKKA crashed using kryo serialization sometimes

2017-03-07 Thread Любен
No, it's all done in the akka serializer thread. I am sure also for LZ4Java that it does not use any parallelism itself. On Tue, Mar 7, 2017 at 5:48 AM, Patrik Nordwall wrote: > Is Kryo (or the library) delegating to a different thread somehow? > > mån 6 mars 2017 kl. 22:

Re: [akka-user] AKKA crashed using kryo serialization sometimes

2017-03-06 Thread Любен
Hi, It's strange, I have put the LZ4 compression in the kryo serialization extension. Actually I am relying on it in production (compiled from the same source). The only difference I see is that it's using the artery transport. Could it be that the source byte buffer is released earlier by artery,

Re: [akka-user] Re: Akka Java IO TLS

2016-08-04 Thread Любен
I have found handing SSL/TLS from JVM a PITA. Why you don't put the SSL termination in front of the Akka HTTP endpoint (e.g. nginx) ? On Wed, Jul 27, 2016 at 4:36 PM, Akka Team wrote: > The easiest path would probably be Akka Streams for TCP ( > http://doc.akka.io/docs/akka/2.4/scala/stream/stre

Re: [akka-user] com.github.romix.akka:akka-kryo-serialization_2.11 and AES Transform?

2016-05-27 Thread Любен
The security of the AES encryption depends on using non-repeating IVs (nounces) and it will result in different cyphertext. Regards, luben On Thu, May 26, 2016 at 7:31 AM, kraythe wrote: > I have Been integrating this extension (which is mentioned in the Akka > docs and is great) and I am havin

Re: [akka-user] Custom Serialization with FST or Kryo ?

2016-05-27 Thread Любен
Have you tried Akka-Kryo-Serializatio[1] ? It should work out of the box with "default" or "automatic" id-strategy. And it has other optional parts that may come handy, e.g. transparent compression using LZ4 or AES encryption. Regards, luben [1] https://github.com/romix/akka-kryo-serialization

Re: [akka-user] Remoting transport back-pressure

2016-02-16 Thread Любен
Hi Guido, Thanks for the pointer to the chopping head mailbox. I will take a look, sounds really interesting. I am already using different bounded mailboxes between the Source and the Processing actor depending on the semanitcs of the computation: if the source is shared between multiple processin

Re: [akka-user] Remoting transport back-pressure

2016-02-15 Thread Любен
Hi Michael, I have taken another approach. I already had a Send/Ack flow control over the network. So I extended it to use the 'ask' and wait for the Ack from the collecting actor in order to exersice back-pressure to the source. Using blocking and bounded queue will also block the source after th

[akka-user] Re: Akka-Http with ActorPublisher source

2015-03-31 Thread Любен Каравелов
Thanks Konrad, The implicit workaround is working for me. I will keep a look on the issue. Regards, luben On Tuesday, March 31, 2015 at 12:20:29 AM UTC+1, Любен Каравелов wrote: > > Hi, > > I have built a small HTTP EventSource endpoint prototype based on > akka-streams-1.0-

[akka-user] Akka-Http with ActorPublisher source

2015-03-30 Thread Любен Каравелов
Hi, I have built a small HTTP EventSource endpoint prototype based on akka-streams-1.0-M3 for a system that I am working on. It turned quite well. I have tried to upgrade it to 1.0-M5 and I can't figure out how to create HttpEntity out of an ActorPublisher. In short, I have ActorPublisher that

[akka-user] Secure-cookie not realy secure

2014-01-27 Thread Любен Каравелов
Hello, I was looking these days about a light-weight transport authentication for akka remoting. SSL is heavy and could not authenticate clients as far as I understand the implementation in akka/remote/transport/netty/NettySSLSupport.scala. The other option that I was looking into is using akk