[akka-user] Could somebody explain what avoid inbound connections from other cluster nodes means?
In http://doc.akka.io/docs/akka/2.3.0/contrib/cluster-client.html there is following sentence: Response messages from the destination actor are tunneled via the receptionist to avoid inbound connections from other cluster nodes to the client Could somebody explain why this is necessary? I am struggling with the phrase avoid inbound connections -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] Akka cluster multi-jvm test - is it possible to simulate a network partition?
Hi. Is there a way I can simulate a network partition using sbt-multijvm and tools like testConductor.blackhole? I've been trying for a couple of hours but I haven't been successful. I won't even post my attempts because they are really useless :D Has any of you ever done that? Thanks G -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Akka 2.3.12 Released!
Excellent work everyone, especially fixing that pesky TCP bug! On Thu, Jul 9, 2015 at 10:56 AM, Martynas Mickevičius martynas.mickevic...@typesafe.com wrote: *Dear hAkkers,* We—the Akka committers—are pleased to be able to announce the availability of Akka 2.3.12. This is the twelfth maintenance release of the 2.3 branch. This release contains a few important fixes: - a fix for a race between Terminated message and final write in TCP ( #17932 https://github.com/akka/akka/issues/17932) - a fix for CircuitBreaker where concurrent transitions did not occur ( #17415 https://github.com/akka/akka/issues/17415) - improvement in flow control of system message delivery (#17554 https://github.com/akka/akka/issues/17554) This release also adds a configurable TestActor creation timeout in TestKit https://github.com/akka/akka/issues/17711, suppresses Tcp.CloseCommand from logging https://github.com/akka/akka/issues/17572 and improves documentation (#17669 https://github.com/akka/akka/issues/17669, #15569 https://github.com/akka/akka/issues/15569). Akka 2.3.12 is released for Scala 2.10.4 and 2.11.5. This release is backwards binary compatible with all previous 2.3.x versions which means that the new JARs are a drop-in replacement for the old one (but not the other way around) as long as your build does not enable the inliner (Scala-only restriction). Always make sure to use at least the latest version required by any of your project’s dependencies. Migrating from Older Relases When migrating an existing project from Akka 2.2.x please have a look at the migration guide http://doc.akka.io/docs/akka/2.3.11/project/migration-guide-2.2.x-2.3.x.html . Additional Release Details The artifacts comprising this release have been published to https://oss.sonatype.org/content/repositories/releases/ and also to Maven Central. In addition, we adopted the sbt standard of encoding the Scala binary version in the artifact name, i.e. the core actor package’s artifactId is “akka-actor_2.10” or “akka-actor_2.11”, respectively. The complete list of closed tickets can be found in the 2.3.12 github issues milestone https://github.com/akka/akka/issues?q=milestone%3A2.3.12. Credits commits added removed 9 138 36 Patrik Nordwall 383 7 Konrad Malawski 3 110 200 Martynas Mickevičius 283 5 Roland Kuhn 217 2 Endre Sándor Varga 1 1 1 hepin 112 23 kukido *Happy hAkking!* -- Martynas Mickevičius Typesafe http://typesafe.com/ – Reactive http://www.reactivemanifesto.org/ Apps on the JVM -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Cheers, √ -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] Akka 2.3.12 Released!
*Dear hAkkers,* We—the Akka committers—are pleased to be able to announce the availability of Akka 2.3.12. This is the twelfth maintenance release of the 2.3 branch. This release contains a few important fixes: - a fix for a race between Terminated message and final write in TCP ( #17932 https://github.com/akka/akka/issues/17932) - a fix for CircuitBreaker where concurrent transitions did not occur ( #17415 https://github.com/akka/akka/issues/17415) - improvement in flow control of system message delivery (#17554 https://github.com/akka/akka/issues/17554) This release also adds a configurable TestActor creation timeout in TestKit https://github.com/akka/akka/issues/17711, suppresses Tcp.CloseCommand from logging https://github.com/akka/akka/issues/17572 and improves documentation (#17669 https://github.com/akka/akka/issues/17669, #15569 https://github.com/akka/akka/issues/15569). Akka 2.3.12 is released for Scala 2.10.4 and 2.11.5. This release is backwards binary compatible with all previous 2.3.x versions which means that the new JARs are a drop-in replacement for the old one (but not the other way around) as long as your build does not enable the inliner (Scala-only restriction). Always make sure to use at least the latest version required by any of your project’s dependencies. Migrating from Older Relases When migrating an existing project from Akka 2.2.x please have a look at the migration guide http://doc.akka.io/docs/akka/2.3.11/project/migration-guide-2.2.x-2.3.x.html . Additional Release Details The artifacts comprising this release have been published to https://oss.sonatype.org/content/repositories/releases/ and also to Maven Central. In addition, we adopted the sbt standard of encoding the Scala binary version in the artifact name, i.e. the core actor package’s artifactId is “akka-actor_2.10” or “akka-actor_2.11”, respectively. The complete list of closed tickets can be found in the 2.3.12 github issues milestone https://github.com/akka/akka/issues?q=milestone%3A2.3.12. Credits commits added removed 9 138 36 Patrik Nordwall 383 7 Konrad Malawski 3 110 200 Martynas Mickevičius 283 5 Roland Kuhn 217 2 Endre Sándor Varga 1 1 1 hepin 112 23 kukido *Happy hAkking!* -- Martynas Mickevičius Typesafe http://typesafe.com/ – Reactive http://www.reactivemanifesto.org/ Apps on the JVM -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] Akka Streams and Google Cloud Storage
Hi Looking at the Google Storage java client libraries these are using blocking I/O as far as I can understand. I'm considering investing some time into building a solution that would use akka-streaming directly against the REST API and my own JWT IDP for signing cookies. It is tempting since I already have the JWT IDP but it is still a bit of work though, so I thought I'd ask here first. Is there anyone who have experience with using Google Cloud Storage (either API or client) and akka-streams, if so do you wish to share how you approached it? /Magnus -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] Re: How can I be notified if a message send to ClusterClient cannot be delivered because that cluster is down?
I looked at scala source code and see that when no backend connection exists the message is stashed. So I guess my only option is to work with a receive timeout on the sender of the message... Am Donnerstag, 9. Juli 2015 11:54:57 UTC+2 schrieb john@gmail.com: If the cluster backend goes down the clusterclient from now on logs Association with remote system [akka.tcp://Cluster@127.0.0.1:8098] has failed, address is now gated I would expect a message that is now send to the ClusterClient to be forwarded to death letters. But this doesn't happen. How can I get notified that this message cannot be delivered? -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] How can I be notified if a message send to ClusterClient cannot be delivered because that cluster is down?
If the cluster backend goes down the clusterclient from now on logs Association with remote system [akka.tcp://Cluster@127.0.0.1:8098] has failed, address is now gated I would expect a message that is now send to the ClusterClient to be forwarded to death letters. But this doesn't happen. How can I get notified that this message cannot be delivered? -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] problem with Testing persistence actor
Hi , I hope that this is the right place for this question,. I am trying to run tests on persistence actor - all tests pass,however when running all tests with maven I am getting [ERROR] [07/09/2015 12:18:50.410] [systemTest-akka.actor.default-dispatcher-4] [akka://systemTest/system/journal] IO error: lock /journal/LOCK: already held by process each test class have different ActorSystem (using TestKit) , each actor have a unique name (e.g system.actorOf(MyActor.props(UUID)) . why am I still getting this lock ? what am I doing wrong ? Please advise Thanks Avi -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] Re: Could somebody explain what avoid inbound connections from other cluster nodes means?
here is the code https://github.com/akka/akka/blob/master/akka-cluster-tools/src/main/scala/akka/cluster/client/ClusterClient.scala#L523 https://github.com/akka/akka/blob/master/akka-cluster-tools/src/main/scala/akka/cluster/client/ClusterClient.scala#L612 I don't see why it is necessary to wrap the client in a tunnel actor other than setting a timeout. How does the tunnel protect the client? whats wrong with pubSubMediator.tell(msg, sender()) Am Donnerstag, 9. Juli 2015 19:23:15 UTC+2 schrieb john@gmail.com: In http://doc.akka.io/docs/akka/2.3.0/contrib/cluster-client.html there is following sentence: Response messages from the destination actor are tunneled via the receptionist to avoid inbound connections from other cluster nodes to the client Could somebody explain why this is necessary? I am struggling with the phrase avoid inbound connections -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] ShardRegion vs EventBus
We're not using Akka Cluster yet, but I have an entity actor type that is ripe for sharding. But there's a complication. The numerous entities are receiving event data for various channels, and rather than receiving messages directly from the supervisor, the supervisor publishes them to an EventBus with LookupClassification, and the entities subscribe to that bus. Works quite well, but this means there's not a spot to send a message to the ShardRegion instead. Thoughts? -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] Re: problem with Testing persistence actor
What type of journal/storage are you using? Perhaps you are sharing the default LevelDB journal which is meant for one actor only and having multiple tests trying to access it concurrently? I would recommend using the in memory journal found on community contributions page when running tests. /Magnus Den torsdag 9 juli 2015 kl. 11:35:50 UTC+2 skrev Avi: Hi , I hope that this is the right place for this question,. I am trying to run tests on persistence actor - all tests pass,however when running all tests with maven I am getting [ERROR] [07/09/2015 12:18:50.410] [systemTest-akka.actor.default-dispatcher-4] [akka://systemTest/system/journal] IO error: lock /journal/LOCK: already held by process each test class have different ActorSystem (using TestKit) , each actor have a unique name (e.g system.actorOf(MyActor.props(UUID)) . why am I still getting this lock ? what am I doing wrong ? Please advise Thanks Avi -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Re: problem with Testing persistence actor
Thanks , I am using the default journal . when I run the tests from the IDE (intellij ) tthey run fine , I am getting that error when I run tests from maven (mvn clean install or test ) 2015-07-09 22:51 GMT+03:00 Magnus Andersson magnus.anders...@mollyware.se: What type of journal/storage are you using? Perhaps you are sharing the default LevelDB journal which is meant for one actor only and having multiple tests trying to access it concurrently? I would recommend using the in memory journal found on community contributions page when running tests. /Magnus Den torsdag 9 juli 2015 kl. 11:35:50 UTC+2 skrev Avi: Hi , I hope that this is the right place for this question,. I am trying to run tests on persistence actor - all tests pass,however when running all tests with maven I am getting [ERROR] [07/09/2015 12:18:50.410] [systemTest-akka.actor.default-dispatcher-4] [akka://systemTest/system/journal] IO error: lock /journal/LOCK: already held by process each test class have different ActorSystem (using TestKit) , each actor have a unique name (e.g system.actorOf(MyActor.props(UUID)) . why am I still getting this lock ? what am I doing wrong ? Please advise Thanks Avi -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to a topic in the Google Groups Akka User List group. To unsubscribe from this topic, visit https://groups.google.com/d/topic/akka-user/OeRJCCiCk0o/unsubscribe. To unsubscribe from this group and all its topics, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] akka-http-extensions 0.5-RC4
Hi all, I updated my akka-http-extensions ( https://github.com/denigma/akka-http-extensions ) to 0.5-RC4 So, now it also contains allow directive that allows to restrict access to inner route to some users within some realm. I wonder, what else do you think would be useful for most of akka-http web applications (apart from registration/authentification/authorization that I already have)? -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Missing javadsl from akka-http-testkit-experimental_2.11 1.0-RC4
This is really strange. I have registered an issue https://github.com/akka/akka/issues/17956. On Thu, Jul 2, 2015 at 10:10 PM, Martijn Blankestijn martijnblankest...@gmail.com wrote: Hi, If I look at the contents of dependency groupIdcom.typesafe.akka/groupId *artifactIdakka-http-testkit-experimental_2.11/artifactId* version1.0-RC4/version /dependency I am missing the package akka.http.javadsl.testkit for running the unit tests in Java. Is this separated in another dependency or just missing? Kind regards, Martijn Blankestijn -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martynas Mickevičius Typesafe http://typesafe.com/ – Reactive http://www.reactivemanifesto.org/ Apps on the JVM -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
