Re: [akka-user] Re: Akka and Streams Concurrency Fundamentals

Hi Johan and Patrik, Thanks very much for your responses; and I'm just getting back to this. Here's a cheeky request: * Any chance you guys could Blog and put Links to GitHub for "Newbie Reference Implementations" for putting together focused learning code samples for these kinds of

Re: [akka-user] Re: How to Test WebSocket Streams

Hi! Just getting back to this; and THANKS for the sbt dependencies info -- I'll have to try that out. It looks like I already had the http testkit; but you're using an additional "test" specifier ...; and then your ScalaTest note is helpful too. Would be awesome for Scala/Akka to have the

Re: [akka-user] Configuration of SerializationBindings Programmatically?

They specify the config just like any other serializer, with the serialization bindings. They have no examples of how to do it via code. But I think I can run with this, thanks. On Friday, September 9, 2016 at 4:12:50 PM UTC-5, Justin du coeur wrote: > > On Fri, Sep 9, 2016 at 3:49 PM, kraythe

Re: [akka-user] Configuration of SerializationBindings Programmatically?

(Never mind -- I think I'm misinterpreting what you're trying to accomplish...) On Fri, Sep 9, 2016 at 5:12 PM, Justin du coeur wrote: > On Fri, Sep 9, 2016 at 3:49 PM, kraythe wrote: > >> I am using Akka-kryo by Roman Levenshtein >>

Re: [akka-user] Configuration of SerializationBindings Programmatically?

On Fri, Sep 9, 2016 at 3:49 PM, kraythe wrote: > I am using Akka-kryo by Roman Levenshtein > as recommended on the > akka serialization page. I know all about Kryo and have used it many times > before. I can integrate it with

Re: [akka-user] Configuration of SerializationBindings Programmatically?

use withFallback(ConfigFactory.load(cl)) -- Cheers, √ On Sep 9, 2016 22:24, "kraythe" wrote: > Doh, didn't know that was there. Bah. Sorry but thanks. :) > > Do I need to worry about defining any bindings for Akka types such as > com.google.protobuf.Message or can I safely

Re: [akka-user] Configuration of SerializationBindings Programmatically?

Doh, didn't know that was there. Bah. Sorry but thanks. :) Do I need to worry about defining any bindings for Akka types such as com.google.protobuf.Message or can I safely ignore those without causing problems. ? On Friday, September 9, 2016 at 3:11:22 PM UTC-5, Konrad Malawski wrote: > >

Re: [akka-user] Configuration of SerializationBindings Programmatically?

parseMap +1 -- Konrad `ktoso` Malawski Akka @ Lightbend On 9 September 2016 at 22:10:33, Viktor Klang (viktor.kl...@gmail.com) wrote: ConfigFactory.parseMap? -- Cheers, √ On Sep 9, 2016 22:01, "kraythe" wrote: > Yeah, that much I

Re: [akka-user] Configuration of SerializationBindings Programmatically?

ConfigFactory.parseMap? -- Cheers, √ On Sep 9, 2016 22:01, "kraythe" wrote: > Yeah, that much I know. However, I have a map of Class -> id in code and I > want to create serialization bindings to this serializer for each of the > types in that map's key set and assign type

Re: [akka-user] Configuration of SerializationBindings Programmatically?

Yeah, that much I know. However, I have a map of Class -> id in code and I want to create serialization bindings to this serializer for each of the types in that map's key set and assign type ids based on the map. What I am trying to do is figure out how to create the ConfigValue object

Re: [akka-user] Configuration of SerializationBindings Programmatically?

The ActorSystem takes an optional Config when created[1], create that Config object programmatically and do withFallback(ConfigFactory.load(classloader)) [1]: https://github.com/akka/akka/blob/master/akka-actor/src/main/scala/akka/actor/ActorSystem.scala#L141 On Fri, Sep 9, 2016 at 9:49 PM,

Re: [akka-user] Configuration of SerializationBindings Programmatically?

I am using Akka-kryo by Roman Levenshtein as recommended on the akka serialization page. I know all about Kryo and have used it many times before. I can integrate it with manual config and it works fine. Thats not my point. I want to configure

Re: [akka-user] Configuration of SerializationBindings Programmatically?

Don't have an answer off the cuff -- the answer probably depends on the Kryo plugin that you're using. My recommendation is to take a dig through the akka-kryo-serialization source code , particularly the KryoSerializer class

Re: [akka-user] Akka Multithreading on Akka-Cluster

On Fri, Sep 9, 2016 at 2:51 PM, Guido Medina wrote: > The problem with explicit is that there are so many "trait" and "classes" > not really registered which is why I use it, > it is the newest ID strategy as it register things you might not care but > commonly used messages

[akka-user] Configuration of SerializationBindings Programmatically?

Greetings, In reference to the configuration of serialization bindings I would like to do this programatically instead of using the config file. I have a type with a static map of types and binding ids based on a Kryo plugin to Akka. What I would like to do is create bindings based on that

Re: [akka-user] Akka Multithreading on Akka-Cluster

The problem with explicit is that there are so many "trait" and "classes" not really registered which is why I use it, it is the newest ID strategy as it register things you might not care but commonly used messages you register, that way you get performance for what is important and automatic

[akka-user] Cluster seed nodes resulting in multiple split brains?

Greetings, We are having some problems with our cluster configuration that manifest themselves in the following log lines (redacted for confidentiality reasons. Sep 09 00:58:10 host1.mycompany.com application-9001.log: 2016-09-09 05:58: 10 + - [WARN] - [OrdersActor]

Re: [akka-user] Re: Kryo serialization not working?

See the other thread -- this confirms what I was saying. The receiving Actor hasn't registered anything for ActorRef, so it's going splat... On Fri, Sep 9, 2016 at 12:37 PM, antonio meo wrote: > Sorry Guys, > I'm testing an Akka-Cluster with two actor that send one to

Re: [akka-user] Akka Multithreading on Akka-Cluster

On Fri, Sep 9, 2016 at 12:27 PM, Guido Medina wrote: > Also, what ID strategy are you using? I see none configured so it it is > using the default, try setting it like I posted in the example which is > "automatic" > Yeah, this is what I was going to suggest. The default

[akka-user] Re: Kryo serialization not working?

Sorry Guys, I'm testing an Akka-Cluster with two actor that send one to an another a custom message formed by two Strings and an ActorRef. When the second actor receives the message (serialized with kryo) it just become unreachable. That's the trace of the second actor: 00:35 TRACE: [kryo]

[akka-user] Re: Akka Multithreading on Akka-Cluster

And newest Akka Kryo doesn't require pool-size as that's a java.util.ConcurrentLinkedQueue by default. I contributed that new mechanism to use ConcurrentLinkedQueue for the pool or your own implementation (See KryoQueueBuilder example in their doc). On Monday, September 5, 2016 at 10:22:28 AM

Re: [akka-user] Akka Multithreading on Akka-Cluster

Also, what ID strategy are you using? I see none configured so it it is using the default, try setting it like I posted in the example which is "automatic" On Friday, September 9, 2016 at 5:26:00 PM UTC+1, Guido Medina wrote: > > Are you sharing the same conf file? if you registered classes

Re: [akka-user] Akka Multithreading on Akka-Cluster

Are you sharing the same conf file? if you registered classes then all nodes must share the same Kryo config. On Friday, September 9, 2016 at 3:44:38 PM UTC+1, silvio poma wrote: > > Just to be clear, my class: com.test.common.LoginRequest is formed of 4 > strings and an actorRef > Thanks all

[akka-user] Terminate ActorSystem on stream failure

Hi, How can I terminate the ActorSystem running my stream when the stream fails? If I have the following stream: A -> B -> C and B fails with a stoppingStrategy, what happens exactly? A and C actors are still running? How can I catch such stopping to then terminate the ActorSystem? I think

[akka-user] ANNOUNCE: New Remoting Milestone 4

Dear hakkers, We are pleased to announce the availability of the fourth development milestone of the new Akka Remoting, codenamed Artery. It’s a development preview and we encourage you to try it out and give us feedback, but it’s not intended for production usage yet. The version number is

Re: [akka-user] Re: Testing routes and marshalling

Hi Richard, The HTTP Testkit expects to have gotten the reply already when check executes, so that is why it does not work. You can use the autopilot feature of the TestProbe or a custom test actor responding the way you want in the test, it could also keep incoming requests for later

Re: [akka-user] Re: Kryo serialization not working?

Good that you figured it out, and thanks for sharing what was wrong rather than leaving the question open! -- Johan Akka Team On Fri, Sep 9, 2016 at 2:28 AM, Federico Nusymowicz wrote: > DERP. I was supposed to nest serializers and serialization-bindings under >

Re: [akka-user] GPU computing with akka

No, no plans currently -- Johan Akka Team On Fri, Sep 9, 2016 at 4:02 AM, Zhaojie Niu wrote: > Dear Johan: > > Thanks for your reply. > > Does Akka team have any plans to support GPU? > > 在 2016年9月8日星期四 UTC+8下午10:08:32，Akka Team写道： >> >> Hi Zhaoije, >> >> No we are not

Re: [akka-user] Akka Multithreading on Akka-Cluster

Just to be clear, my class: com.test.common.LoginRequest is formed of 4 strings and an actorRef Thanks all 2016-09-09 16:34 GMT+02:00 silvio poma : > Right now one of the biggest and strange problem is that when arrive a > message from the Actor A in the node 1 to the

Re: [akka-user] Akka Multithreading on Akka-Cluster

Right now one of the biggest and strange problem is that when arrive a message from the Actor A in the node 1 to the actor B in the node 2 the node 2 is immediately disassociated from the cluster. The message that the actor A sends to actor B is our custom class that we are serializing using

Re: [akka-user] Akka Multithreading on Akka-Cluster

What problems are you facing? I'm in my second project with Java 8 + Akka so maybe I can help. To integrate the akka-kryo extension all you need is the dependency and few lines at the configuration you are using, no code changes are needed, here is an example: akka { // Log4j2 extension

Re: [akka-user] GPU computing with akka

Dear Johan: Thanks for your reply. Does Akka team have any plans to support GPU? 在 2016年9月8日星期四 UTC+8下午10:08:32，Akka Team写道： > > Hi Zhaoije, > > No we are not working on anything like that, and the project mentioned > does not seem to have been touched in the last 5 years. > > If there are JVM

Re: [akka-user] Data from tcp to a dynamically balanced stream does not work

Hi Ismail, Please create a minimized, runnable code example, preferably with a test that reproduces the situation. On Fri, Sep 9, 2016 at 11:02 AM, Ismail Kelebek wrote: > I have a problem while forwarding data received from tcp to a stream . It > works with

[akka-user] Data from tcp to a dynamically balanced stream does not work

I have a problem while forwarding data received from tcp to a stream . It works with hardcoded version but does not work with dynamic balance graph . If i change the rtcpgraph with rtcpgraphdynamic, data does not flow into stream as if its run method is missing . Data arrives at publisher

Re: [akka-user] Akka Multithreading on Akka-Cluster

Hi Guys, Thanks a lot everybody. Yours tips were very useful and we are working on it. We've already improved the router and the disptachers configuration achieving very good results. Now we are trying to leave the java serialization and pass to another one more efficient, but we are having

Re: [akka-user] Akka Multithreading on Akka-Cluster

Hi Guys, Thanks a lot everybody. Your tips were very useful and we are working on it. We've already improved the router and the disptachers configuration achieving very good results. Now we are trying to leave the java serialization and pass to another one more efficient, but we are having some