moru0011
moru0011
Examples for kontraktor scaleout: this is the original system kontraktor was developed for: http://java-is-the-new-c.blogspot.de/2013/12/big-data-reactive-way.html distributed Lambda execution: https://www.juptr.io/juptrblogs/a2b6139f-b273-42bd-b533-e4695e27e353.html sharded NLP + document query https://www.juptr.io/juptrblogs/c7839e9a-da8b-4a60-bc66-94558c30c4da.html
quite busy at the moment :) srry
you are probably accessing the actor proxy. Each actor ref is actually a proxy with class == actor class but empty state. the actor proxy (== actor ref) is generated...
erm .. ? in case you'd like to investigate into that direction, the general idea would be to mask this is a special kind of Remoting Transport (e.g. ChronicleQueuePublisher +...
hum :) .. AFAIk in this scenario it can be signaled back via rejecting a promise only. As sloppy programming frequently does ignore async errors `(result,error) -> if ( result...
(I'll reply in detail tomorrow, no time now) 1. if your platform only allows for TCP (so the sender actually replicates a message to N receivers) it should be straight...
you can checkout / view the example project here: https://github.com/RuedigerMoeller/kontraktor/tree/trunk/examples/pub-sub/tcp-based/src/main/java/pubsub/point2point - websockets based pub-sub (requires mediator service ["gossip server"]). Could also switch to TCP easily - supports topics - supports...
see modules/reactive-streams. passes the TCK, but is not yet on maven + undocumented. Using generic actor remoting you can transparently remote reactive-streams at high message rates (see reactive-streams example)
available with 3.04
I had similar problems in the past ``` xml org.deeplearning4j deeplearning4j-ui 0.4-rc3.8 org.slf4j slf4j-log4j12 ch.qos.logback logback-classic org.deeplearning4j deeplearning4j-nlp 0.4-rc3.8 org.slf4j slf4j-log4j12 ch.qos.logback logback-classic org.nd4j nd4j-jblas 0.4-rc3.6 org.slf4j slf4j-log4j12 ch.qos.logback logback-classic...