[akka-user] Re: Cassandra Time Stamp Problem and How Akka can help?

What is each Entity if I may ask? By Entity you mean Actor? If I shard messages across group of actors or actor systems through some user specified function and say an actor or actor system(a node) dies then Does Akka redirect that shard to other actors (more like rebalancing) ? Any simple

Re: [akka-user] Disable hostname verification

Got it thanks! On Wednesday, March 15, 2017 at 4:25:13 AM UTC-5, Konrad Malawski wrote: > > Read the docs: > > http://doc.akka.io/docs/akka/current/scala/http/client-side/https-support.html#Hostname_verification > > You should also force the SSL Config library to be 0.2.2 >

Re: [akka-user] Cassandra Time Stamp Problem and How Akka can help?

You may want to take a look at the combination of Akka Cluster Sharding, and Akka Persistence over Cassandra -- that's the most-idiomatic Akka way to deal with this. Cluster Sharding says that each Entity is represented at most once in the cluster (so you don't have multiple nodes contending for

[akka-user] Re: Naive question

One option, which may not be feasible depending on your use case, is to simply replay *all* events from scratch, rebuilding current state on the fly when needed. If you can configure enough retention on your Kafka cluster, it's an option. Another is to keep periodic snapshots so that you have

[akka-user] Re: AKKA HTTP: Is this a valid use of Route.seal?

Hi Alan, yes, that's a valid use case. The route tree is usually traversed completely until a Route matches. But if you know that the search can be cut short, then `seal` is definitely a good solution. Another solution would be to use only `handleRejections` which would have the advantage that

Re: [akka-user] Akka Streams + TCP + TLS

I was able to resolve the issue ... I had to change the version of .jar ssl-config-core_2.12.0-M3-0.2.1.jar By ssl-config-core_2.12-0.2.2.jar Thanks again El miércoles, 15 de marzo de 2017, 11:25:42 (UTC-3), Pablo Milanese escribió: > > Totally agree .. However, maybe explaining my error

[akka-user] Event Stream and Routers

I'm trying to use the event stream bus to publish a message that has to be picked up by a router implemented as a "smallest-mailbox-pool". I noticed that only two of the 5 router's routees actually receive the message. Is that the expected behaviour? I could be using a Broadcast message, but

Re: [akka-user] Akka Streams + TCP + TLS

Totally agree .. However, maybe explaining my error better, can give me a clue. I suspect that my mistake can be due to two things: (1) Some conversion between scala - java8, given the new "compatibility" between scala 12 and java 8 .. (2) The fact that scala 2.11 and 2.12 are not binary

Re: [akka-user] Akka Streams + TCP + TLS

Uhm... please use some serious dependency management tool. You're missing ssl-config. Please read the dependencies that the projects have, you simply are missing things from your dependencies. -- Konrad `ktoso` Malawski Akka @ Lightbend On 15 March 2017

Re: [akka-user] Akka Streams + TCP + TLS

Buenas! Java 1.8.0_121 Scala 2.12.1 I have no SBT .. We use Ivy in a local repository: For example: (All the next jars, are for scala 2.12.. for example: akka-stream_2.12) Jars: akka-actor.jar akka-camel.jar akka-protobuf.jar akka-remote.jar akka-slf4j.jar akka-stream-testkit.jar

Re: [akka-user] Multi-jvm example of testing of Cluster Singleton recreation after one JVM crash ?

I see that this official Activator project *"Distributed workers with Akka and Scala"* http://www.lightbend.com/activator/template/akka-distributed-workers pointed in this documentation http://doc.akka.io/docs/akka/2.4.17/scala/cluster-client.html#An_Example is tested *without Multi-Jvm*. I'm

Re: [akka-user] Akka Streams + TCP + TLS

What JVM and Scala versions are you using? What are your project's dependency versions? hint: os shell> java -version sbt> scalaVersion sbt> libraryDependencies cheers, Rafał W dniu wtorek, 14 marca 2017 20:23:15 UTC+1 użytkownik Pablo Milanese napisał: > > Hi Konrad, > > At the first view, I

[akka-user] Re: Naive question

if my current state A = {key1: val1, key2: val2, ...key50: val50} and the next state B = {key1: val1, key2: val2, ...key5: val5} then Persistence actor would store A-B = {key6: val6, key7: val7, ...key50: val50} ? On Tuesday, March 14, 2017 at 10:20:42 AM UTC-7, kant kodali wrote:

Re: [akka-user] Disable hostname verification

Read the docs: http://doc.akka.io/docs/akka/current/scala/http/client-side/https-support.html#Hostname_verification You should also force the SSL Config library to be 0.2.2 -- Konrad `ktoso` Malawski

Re: [akka-user] Akka Pool Router

It is hard to explain, but in short my master actor receives a message which is then forwarded to the respective worker, and from that message I extract business information to make my worker's (FSM) persistenceId unique. After I second thought, maybe I misunderstood the router concept - I

Re: [akka-user] Disable hostname verification

Hi Team, How do we disable Host verification using Akka http? Getting below exception. akka.stream.ConnectionException: Hostname verification failed! Code: http.setDefaultClientHttpsContext(HttpsConnectionContext.https(context)); conSecure = ConnectHttp.toHostHttps(properties.getHost(),

Re: [akka-user] Akka Pool Router

What persistenceIds would you like to use in the end? Based on a counter? PO-1, PO-2, ... increasing for each routee? Would be strange in a long running system when worker nodes are added and removed over time. Why not use Cluster Sharding instead? Wouldn't it be more natural to have a separate