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:
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,
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
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
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
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
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
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-
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
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
10 matches
Mail list logo