Are those exceptions because you send new messages to the entity actor? Do they stop when you stop sending messages to the actor?
BackoffSupervisor only helps for persist failures (database exception) or failures during recovery, i.e. when the actor is stopped. If you throw exception in receiveCommand it will trigger a normal restart, which will trigger a persistent actor replay. Please read this section of the docs: http://doc.akka.io/docs/akka/2.4.0/scala/persistence.html#Failures Also, try the BackoffSupervisor. Let me know if you still have problems after that and we will try to sort them out. Regards, Patrik On Thu, Nov 12, 2015 at 3:54 AM, sd d <[email protected]> wrote: > Hello, > > In a multi node cluster sharding scenario if a persistent actor throws an > exception, it is not propagating to the Parent Actor supervisor strategy, > instead the persistent actor retries for ever, I haven't tried the > BackOffSupervisor yet but does it help in propagating the exception to the > parent actor or it periodically increases the timeout and tries again and > again till the exception is resolved. > > Ideally, if there is a database exception in the persistent actor, i would > like the supervisor actor open the circuit breaker. So, far I haven't had > much success in getting this to work. > > I looked at the following thread, looks like this has been resolved in > Akka 2.4 release. > https://github.com/akka/akka/issues/18487 > > I took an example from this URL ( > https://github.com/henrymai/akka/blob/master/akka-cluster-sharding/src/test/java/akka/cluster/sharding/ClusterShardingTest.java) > and added an exception scenario to test the exception propagation scenario > but it is not working as expected instead re-tries for ever following is > the sample log. > > My changes can be found at this github URL ( > https://github.com/sdab75/akka-cluster-sharding-test/blob/master/src/main/java/akka/cluster/sharding/ClusterShardingTest.java), > this example will recreate the exception i was talking about. > > I am just wondering, if any of got this scenario working. Appreciate any > help in resolving this issue. > > I generate the exception the following way. > > void updateState(CounterChanged event) { > System.out.println("updating ###################"); > if(true){ > throw new RuntimeException("Intentional Error > @@@@@@@@@@@@@@@@@@@@@@@@"); > } > count += event.delta; > } > > > > > Error Log: > > C:\java\jdk1.8.0_25\bin\java -Didea.launcher.port=7533 > "-Didea.launcher.bin.path=C:\Program Files (x86)\JetBrains\IntelliJ IDEA > Community Edition 14.1.5\bin" -Dfile.encoding=windows-1252 -classpath > "C:\java\jdk1.8.0_25\jre\lib\charsets.jar;C:\java\jdk1.8.0_25\jre\lib\deploy.jar;C:\java\jdk1.8.0_25\jre\lib\javaws.jar;C:\java\jdk1.8.0_25\jre\lib\jce.jar;C:\java\jdk1.8.0_25\jre\lib\jfr.jar;C:\java\jdk1.8.0_25\jre\lib\jfxswt.jar;C:\java\jdk1.8.0_25\jre\lib\jsse.jar;C:\java\jdk1.8.0_25\jre\lib\management-agent.jar;C:\java\jdk1.8.0_25\jre\lib\plugin.jar;C:\java\jdk1.8.0_25\jre\lib\resources.jar;C:\java\jdk1.8.0_25\jre\lib\rt.jar;C:\java\jdk1.8.0_25\jre\lib\ext\access-bridge-64.jar;C:\java\jdk1.8.0_25\jre\lib\ext\cldrdata.jar;C:\java\jdk1.8.0_25\jre\lib\ext\dnsns.jar;C:\java\jdk1.8.0_25\jre\lib\ext\jaccess.jar;C:\java\jdk1.8.0_25\jre\lib\ext\jfxrt.jar;C:\java\jdk1.8.0_25\jre\lib\ext\localedata.jar;C:\java\jdk1.8.0_25\jre\lib\ext\nashorn.jar;C:\java\jdk1.8.0_25\jre\lib\ext\sapjco3.jar;C:\java\jdk1.8.0_25\jre\lib\ext\sunec.jar;C:\java\jdk1.8.0_25\jre\lib\ext\sunjce_provider.jar;C:\java\jdk1.8.0_25\jre\lib\ext\sunmscapi.jar;C:\java\jdk1.8.0_25\jre\lib\ext\sunpkcs11.jar;C:\java\jdk1.8.0_25\jre\lib\ext\zipfs.jar;C:\dev\garnet\experiments\akka-cluster-sharding-test\target\classes;C:\Users\davenkat\.m2\repository\org\codehaus\jackson\jackson-mapper-asl\1.9.11\jackson-mapper-asl-1.9.11.jar;C:\Users\davenkat\.m2\repository\org\codehaus\jackson\jackson-core-asl\1.9.11\jackson-core-asl-1.9.11.jar;C:\Users\davenkat\.m2\repository\javax\json\javax.json-api\1.0\javax.json-api-1.0.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot-starter-web\1.2.5.RELEASE\spring-boot-starter-web-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot-starter\1.2.5.RELEASE\spring-boot-starter-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot\1.2.5.RELEASE\spring-boot-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot-autoconfigure\1.2.5.RELEASE\spring-boot-autoconfigure-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot-starter-logging\1.2.5.RELEASE\spring-boot-starter-logging-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\slf4j\jul-to-slf4j\1.7.12\jul-to-slf4j-1.7.12.jar;C:\Users\davenkat\.m2\repository\org\yaml\snakeyaml\1.14\snakeyaml-1.14.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot-starter-tomcat\1.2.5.RELEASE\spring-boot-starter-tomcat-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\apache\tomcat\embed\tomcat-embed-core\8.0.23\tomcat-embed-core-8.0.23.jar;C:\Users\davenkat\.m2\repository\org\apache\tomcat\embed\tomcat-embed-el\8.0.23\tomcat-embed-el-8.0.23.jar;C:\Users\davenkat\.m2\repository\org\apache\tomcat\embed\tomcat-embed-logging-juli\8.0.23\tomcat-embed-logging-juli-8.0.23.jar;C:\Users\davenkat\.m2\repository\org\apache\tomcat\embed\tomcat-embed-websocket\8.0.23\tomcat-embed-websocket-8.0.23.jar;C:\Users\davenkat\.m2\repository\com\fasterxml\jackson\core\jackson-databind\2.4.6\jackson-databind-2.4.6.jar;C:\Users\davenkat\.m2\repository\com\fasterxml\jackson\core\jackson-core\2.4.6\jackson-core-2.4.6.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-core\4.1.7.RELEASE\spring-core-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-web\4.1.7.RELEASE\spring-web-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-webmvc\4.1.7.RELEASE\spring-webmvc-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-rest-webmvc\2.2.3.RELEASE\spring-data-rest-webmvc-2.2.3.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-rest-core\2.2.3.RELEASE\spring-data-rest-core-2.2.3.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\hateoas\spring-hateoas\0.16.0.RELEASE\spring-hateoas-0.16.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\plugin\spring-plugin-core\1.1.0.RELEASE\spring-plugin-core-1.1.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\atteo\evo-inflector\1.2\evo-inflector-1.2.jar;C:\Users\davenkat\.m2\repository\com\fasterxml\jackson\core\jackson-annotations\2.4.6\jackson-annotations-2.4.6.jar;C:\Users\davenkat\.m2\repository\com\github\fge\json-patch\1.7\json-patch-1.7.jar;C:\Users\davenkat\.m2\repository\com\github\fge\jackson-coreutils\1.6\jackson-coreutils-1.6.jar;C:\Users\davenkat\.m2\repository\com\github\fge\msg-simple\1.1\msg-simple-1.1.jar;C:\Users\davenkat\.m2\repository\com\github\fge\btf\1.2\btf-1.2.jar;C:\Users\davenkat\.m2\repository\com\google\code\findbugs\jsr305\2.0.1\jsr305-2.0.1.jar;C:\Users\davenkat\.m2\repository\org\slf4j\slf4j-api\1.7.12\slf4j-api-1.7.12.jar;C:\Users\davenkat\.m2\repository\org\slf4j\jcl-over-slf4j\1.7.12\jcl-over-slf4j-1.7.12.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-hadoop\2.2.0.RELEASE\spring-data-hadoop-2.2.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-context-support\4.1.7.RELEASE\spring-context-support-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-aop\4.1.7.RELEASE\spring-aop-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\aopalliance\aopalliance\1.0\aopalliance-1.0.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-tx\4.1.7.RELEASE\spring-tx-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-hadoop-hbase\2.2.0.RELEASE\spring-data-hadoop-hbase-2.2.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-yarn-common\2.6.0\hadoop-yarn-common-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-yarn-api\2.6.0\hadoop-yarn-api-2.6.0.jar;C:\Users\davenkat\.m2\repository\javax\xml\bind\jaxb-api\2.2.2\jaxb-api-2.2.2.jar;C:\Users\davenkat\.m2\repository\javax\xml\stream\stax-api\1.0-2\stax-api-1.0-2.jar;C:\Users\davenkat\.m2\repository\javax\activation\activation\1.1\activation-1.1.jar;C:\Users\davenkat\.m2\repository\org\apache\commons\commons-compress\1.4.1\commons-compress-1.4.1.jar;C:\Users\davenkat\.m2\repository\org\tukaani\xz\1.0\xz-1.0.jar;C:\Users\davenkat\.m2\repository\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;C:\Users\davenkat\.m2\repository\javax\servlet\servlet-api\2.5\servlet-api-2.5.jar;C:\Users\davenkat\.m2\repository\commons-codec\commons-codec\1.4\commons-codec-1.4.jar;C:\Users\davenkat\.m2\repository\org\mortbay\jetty\jetty-util\6.1.26\jetty-util-6.1.26.jar;C:\Users\davenkat\.m2\repository\com\sun\jersey\jersey-core\1.9\jersey-core-1.9.jar;C:\Users\davenkat\.m2\repository\com\sun\jersey\jersey-client\1.9\jersey-client-1.9.jar;C:\Users\davenkat\.m2\repository\org\codehaus\jackson\jackson-jaxrs\1.9.13\jackson-jaxrs-1.9.13.jar;C:\Users\davenkat\.m2\repository\org\codehaus\jackson\jackson-xc\1.9.13\jackson-xc-1.9.13.jar;C:\Users\davenkat\.m2\repository\commons-logging\commons-logging\1.1.3\commons-logging-1.1.3.jar;C:\Users\davenkat\.m2\repository\commons-cli\commons-cli\1.2\commons-cli-1.2.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-annotations\2.6.0\hadoop-annotations-2.6.0.jar;C:\Users\davenkat\.m2\repository\com\google\inject\extensions\guice-servlet\3.0\guice-servlet-3.0.jar;C:\Users\davenkat\.m2\repository\com\google\protobuf\protobuf-java\2.5.0\protobuf-java-2.5.0.jar;C:\Users\davenkat\.m2\repository\commons-io\commons-io\2.4\commons-io-2.4.jar;C:\Users\davenkat\.m2\repository\com\google\inject\guice\3.0\guice-3.0.jar;C:\Users\davenkat\.m2\repository\javax\inject\javax.inject\1\javax.inject-1.jar;C:\Users\davenkat\.m2\repository\com\sun\jersey\jersey-server\1.9\jersey-server-1.9.jar;C:\Users\davenkat\.m2\repository\com\sun\jersey\jersey-json\1.9\jersey-json-1.9.jar;C:\Users\davenkat\.m2\repository\com\sun\xml\bind\jaxb-impl\2.2.3-1\jaxb-impl-2.2.3-1.jar;C:\Users\davenkat\.m2\repository\com\sun\jersey\contribs\jersey-guice\1.9\jersey-guice-1.9.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-common\2.6.0\hadoop-common-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\commons\commons-math3\3.1.1\commons-math3-3.1.1.jar;C:\Users\davenkat\.m2\repository\xmlenc\xmlenc\0.52\xmlenc-0.52.jar;C:\Users\davenkat\.m2\repository\commons-httpclient\commons-httpclient\3.1\commons-httpclient-3.1.jar;C:\Users\davenkat\.m2\repository\commons-net\commons-net\3.1\commons-net-3.1.jar;C:\Users\davenkat\.m2\repository\commons-collections\commons-collections\3.2.1\commons-collections-3.2.1.jar;C:\Users\davenkat\.m2\repository\org\mortbay\jetty\jetty\6.1.26\jetty-6.1.26.jar;C:\Users\davenkat\.m2\repository\tomcat\jasper-compiler\5.5.23\jasper-compiler-5.5.23.jar;C:\Users\davenkat\.m2\repository\tomcat\jasper-runtime\5.5.23\jasper-runtime-5.5.23.jar;C:\Users\davenkat\.m2\repository\javax\servlet\jsp\jsp-api\2.1\jsp-api-2.1.jar;C:\Users\davenkat\.m2\repository\commons-el\commons-el\1.0\commons-el-1.0.jar;C:\Users\davenkat\.m2\repository\net\java\dev\jets3t\jets3t\0.9.0\jets3t-0.9.0.jar;C:\Users\davenkat\.m2\repository\org\apache\httpcomponents\httpclient\4.3.6\httpclient-4.3.6.jar;C:\Users\davenkat\.m2\repository\org\apache\httpcomponents\httpcore\4.1.2\httpcore-4.1.2.jar;C:\Users\davenkat\.m2\repository\com\jamesmurty\utils\java-xmlbuilder\0.4\java-xmlbuilder-0.4.jar;C:\Users\davenkat\.m2\repository\commons-configuration\commons-configuration\1.6\commons-configuration-1.6.jar;C:\Users\davenkat\.m2\repository\commons-digester\commons-digester\2.1\commons-digester-2.1.jar;C:\Users\davenkat\.m2\repository\commons-beanutils\commons-beanutils\1.9.2\commons-beanutils-1.9.2.jar;C:\Users\davenkat\.m2\repository\commons-beanutils\commons-beanutils-core\1.8.0\commons-beanutils-core-1.8.0.jar;C:\Users\davenkat\.m2\repository\org\apache\avro\avro\1.7.4\avro-1.7.4.jar;C:\Users\davenkat\.m2\repository\com\thoughtworks\paranamer\paranamer\2.3\paranamer-2.3.jar;C:\Users\davenkat\.m2\repository\org\xerial\snappy\snappy-java\1.0.4.1\snappy-java-1.0.4.1.jar;C:\Users\davenkat\.m2\repository\com\google\code\gson\gson\2.3.1\gson-2.3.1.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-auth\2.6.0\hadoop-auth-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\directory\server\apacheds-kerberos-codec\2.0.0-M15\apacheds-kerberos-codec-2.0.0-M15.jar;C:\Users\davenkat\.m2\repository\org\apache\directory\server\apacheds-i18n\2.0.0-M15\apacheds-i18n-2.0.0-M15.jar;C:\Users\davenkat\.m2\repository\org\apache\directory\api\api-asn1-api\1.0.0-M20\api-asn1-api-1.0.0-M20.jar;C:\Users\davenkat\.m2\repository\org\apache\directory\api\api-util\1.0.0-M20\api-util-1.0.0-M20.jar;C:\Users\davenkat\.m2\repository\org\apache\curator\curator-framework\2.6.0\curator-framework-2.6.0.jar;C:\Users\davenkat\.m2\repository\com\jcraft\jsch\0.1.42\jsch-0.1.42.jar;C:\Users\davenkat\.m2\repository\org\apache\curator\curator-client\2.6.0\curator-client-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\curator\curator-recipes\2.6.0\curator-recipes-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\htrace\htrace-core\3.0.4\htrace-core-3.0.4.jar;C:\Users\davenkat\.m2\repository\org\apache\zookeeper\zookeeper\3.4.6\zookeeper-3.4.6.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-distcp\2.6.0\hadoop-distcp-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-hdfs\2.6.0\hadoop-hdfs-2.6.0.jar;C:\Users\davenkat\.m2\repository\commons-daemon\commons-daemon\1.0.13\commons-daemon-1.0.13.jar;C:\Users\davenkat\.m2\repository\xerces\xercesImpl\2.9.1\xercesImpl-2.9.1.jar;C:\Users\davenkat\.m2\repository\xml-apis\xml-apis\1.3.04\xml-apis-1.3.04.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-mapreduce-client-core\2.6.0\hadoop-mapreduce-client-core-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-streaming\2.6.0\hadoop-streaming-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-mapreduce-client-jobclient\2.6.0\hadoop-mapreduce-client-jobclient-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-mapreduce-client-common\2.6.0\hadoop-mapreduce-client-common-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-yarn-client\2.6.0\hadoop-yarn-client-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-yarn-server-common\2.6.0\hadoop-yarn-server-common-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-mapreduce-client-shuffle\2.6.0\hadoop-mapreduce-client-shuffle-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-yarn-server-nodemanager\2.6.0\hadoop-yarn-server-nodemanager-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\fusesource\leveldbjni\leveldbjni-all\1.8\leveldbjni-all-1.8.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-hadoop-pig\2.2.0.RELEASE\spring-data-hadoop-pig-2.2.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\batch\spring-batch-core\3.0.4.RELEASE\spring-batch-core-3.0.4.RELEASE.jar;C:\Users\davenkat\.m2\repository\com\ibm\jbatch\com.ibm.jbatch-tck-spi\1.0\com.ibm.jbatch-tck-spi-1.0.jar;C:\Users\davenkat\.m2\repository\javax\batch\javax.batch-api\1.0\javax.batch-api-1.0.jar;C:\Users\davenkat\.m2\repository\com\thoughtworks\xstream\xstream\1.4.7\xstream-1.4.7.jar;C:\Users\davenkat\.m2\repository\xmlpull\xmlpull\1.1.3.1\xmlpull-1.1.3.1.jar;C:\Users\davenkat\.m2\repository\xpp3\xpp3_min\1.1.4c\xpp3_min-1.1.4c.jar;C:\Users\davenkat\.m2\repository\org\codehaus\jettison\jettison\1.2\jettison-1.2.jar;C:\Users\davenkat\.m2\repository\org\springframework\batch\spring-batch-infrastructure\3.0.4.RELEASE\spring-batch-infrastructure-3.0.4.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-hadoop-batch\2.2.0.RELEASE\spring-data-hadoop-batch-2.2.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-hadoop-hive\2.2.0.RELEASE\spring-data-hadoop-hive-2.2.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-context\4.1.7.RELEASE\spring-context-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-jdbc\4.1.7.RELEASE\spring-jdbc-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-hadoop-core\2.2.0.RELEASE\spring-data-hadoop-core-2.2.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-cassandra\1.2.2.RELEASE\spring-data-cassandra-1.2.2.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-expression\4.1.7.RELEASE\spring-expression-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-commons\1.9.3.RELEASE\spring-data-commons-1.9.3.RELEASE.jar;C:\Users\davenkat\.m2\repository\com\datastax\cassandra\cassandra-driver-dse\2.1.5\cassandra-driver-dse-2.1.5.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-cql\1.2.2.RELEASE\spring-cql-1.2.2.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-beans\4.1.7.RELEASE\spring-beans-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\com\google\guava\guava\16.0.1\guava-16.0.1.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot-starter-amqp\1.2.5.RELEASE\spring-boot-starter-amqp-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-messaging\4.1.7.RELEASE\spring-messaging-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\amqp\spring-rabbit\1.4.5.RELEASE\spring-rabbit-1.4.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\com\rabbitmq\amqp-client\3.5.1\amqp-client-3.5.1.jar;C:\Users\davenkat\.m2\repository\org\springframework\retry\spring-retry\1.1.2.RELEASE\spring-retry-1.1.2.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\amqp\spring-amqp\1.4.5.RELEASE\spring-amqp-1.4.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-redis\1.5.2.RELEASE\spring-data-redis-1.5.2.RELEASE.jar;C:\Users\davenkat\.m2\repository\redis\clients\jedis\2.7.0\jedis-2.7.0.jar;C:\Users\davenkat\.m2\repository\org\apache\commons\commons-pool2\2.2\commons-pool2-2.2.jar;C:\Users\davenkat\.m2\repository\asm\asm\3.3.1\asm-3.3.1.jar;C:\Users\davenkat\.m2\repository\org\objenesis\objenesis\2.1\objenesis-2.1.jar;C:\Users\davenkat\.m2\repository\org\mapstruct\mapstruct\1.0.0.CR1\mapstruct-1.0.0.CR1.jar;C:\Users\davenkat\.m2\repository\org\hibernate\hibernate-validator\5.1.3.Final\hibernate-validator-5.1.3.Final.jar;C:\Users\davenkat\.m2\repository\javax\validation\validation-api\1.1.0.Final\validation-api-1.1.0.Final.jar;C:\Users\davenkat\.m2\repository\org\jboss\logging\jboss-logging\ > 3.1.3.GA\jboss-logging-3.1.3.GA.jar;C:\Users\davenkat\.m2\repository\com\fasterxml\classmate\1.0.0\classmate-1.0.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-actor_2.11\2.4.0\akka-actor_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\org\scala-lang\scala-library\2.11.7\scala-library-2.11.7.jar;C:\Users\davenkat\.m2\repository\com\typesafe\config\1.3.0\config-1.3.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-remote_2.11\2.4.0\akka-remote_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-protobuf_2.11\2.4.0\akka-protobuf_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\io\netty\netty\3.10.3.Final\netty-3.10.3.Final.jar;C:\Users\davenkat\.m2\repository\org\uncommons\maths\uncommons-maths\1.2.2a\uncommons-maths-1.2.2a.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-cluster_2.11\2.4.0\akka-cluster_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-contrib_2.11\2.4.0\akka-contrib_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-cluster-tools_2.11\2.4.0\akka-cluster-tools_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-persistence_2.11\2.4.0\akka-persistence_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-cluster-sharding_2.11\2.4.0\akka-cluster-sharding_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\com\github\krasserm\akka-persistence-cassandra_2.11\0.4\akka-persistence-cassandra_2.11-0.4.jar;C:\Users\davenkat\.m2\repository\com\datastax\cassandra\cassandra-driver-core\2.1.5\cassandra-driver-core-2.1.5.jar;C:\Users\davenkat\.m2\repository\com\codahale\metrics\metrics-core\3.0.2\metrics-core-3.0.2.jar;C:\Program > Files (x86)\JetBrains\IntelliJ IDEA Community Edition > 14.1.5\lib\idea_rt.jar" com.intellij.rt.execution.application.AppMain > akka.cluster.sharding.ClusterShardingTest > [INFO] [11/11/2015 21:53:21.760] [main] [akka.remote.Remoting] Starting > remoting > [INFO] [11/11/2015 21:53:21.949] [main] [akka.remote.Remoting] Remoting > started; listening on addresses :[akka.tcp://[email protected]:2550] > [INFO] [11/11/2015 21:53:21.951] [main] [akka.remote.Remoting] Remoting > now listens on addresses: [akka.tcp://[email protected]:2550] > [INFO] [11/11/2015 21:53:21.962] [main] > [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp:// > [email protected]:2550] - Starting up... > [INFO] [11/11/2015 21:53:22.035] [main] > [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp:// > [email protected]:2550] - Registered cluster JMX MBean > [akka:type=Cluster] > [INFO] [11/11/2015 21:53:22.035] [main] > [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp:// > [email protected]:2550] - Started up successfully > [INFO] [11/11/2015 21:53:22.041] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp:// > [email protected]:2550] - Metrics will be retreived from MBeans, > and may be incorrect on some platforms. To increase metric accuracy add the > 'sigar.jar' to the classpath and the appropriate platform-specific native > libary to 'java.library.path'. Reason: java.lang.ClassNotFoundException: > org.hyperic.sigar.Sigar > [INFO] [11/11/2015 21:53:22.045] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp:// > [email protected]:2550] - Metrics collection has started > successfully > [INFO] [11/11/2015 21:53:22.081] > [ClusterSystem-akka.actor.default-dispatcher-4] > [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp:// > [email protected]:2550] - Node [akka.tcp:// > [email protected]:2550] is JOINING, roles [] > [INFO] [11/11/2015 21:53:23.082] > [ClusterSystem-akka.actor.default-dispatcher-15] > [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp:// > [email protected]:2550] - Leader is moving node [akka.tcp:// > [email protected]:2550] to [Up] > [INFO] [11/11/2015 21:53:23.146] > [ClusterSystem-akka.actor.default-dispatcher-19] [akka.tcp:// > [email protected]:2550/system/sharding/SupervisedCounterCoordinator] > Singleton manager starting singleton actor > [akka://ClusterSystem/system/sharding/SupervisedCounterCoordinator/singleton] > [INFO] [11/11/2015 21:53:23.146] > [ClusterSystem-akka.actor.default-dispatcher-18] [akka.tcp:// > [email protected]:2550/system/sharding/CounterCoordinator] > Singleton manager starting singleton actor > [akka://ClusterSystem/system/sharding/CounterCoordinator/singleton] > [INFO] [11/11/2015 21:53:23.147] > [ClusterSystem-akka.actor.default-dispatcher-18] [akka.tcp:// > [email protected]:2550/system/sharding/CounterCoordinator] > ClusterSingletonManager state change [Start -> Oldest] > [INFO] [11/11/2015 21:53:23.147] > [ClusterSystem-akka.actor.default-dispatcher-19] [akka.tcp:// > [email protected]:2550/system/sharding/SupervisedCounterCoordinator] > ClusterSingletonManager state change [Start -> Oldest] > [INFO] [11/11/2015 21:53:23.147] > [ClusterSystem-akka.actor.default-dispatcher-15] > [akka://ClusterSystem/system/sharding/CounterCoordinator/singleton/coordinator] > Message [akka.cluster.sharding.ShardCoordinator$Internal$Register] from > Actor[akka://ClusterSystem/system/sharding/Counter#1791785555] to > Actor[akka://ClusterSystem/system/sharding/CounterCoordinator/singleton/coordinator] > was not delivered. [1] dead letters encountered. This logging can be turned > off or adjusted with configuration settings 'akka.log-dead-letters' and > 'akka.log-dead-letters-during-shutdown'. > [INFO] [11/11/2015 21:53:23.147] > [ClusterSystem-akka.actor.default-dispatcher-15] > [akka://ClusterSystem/system/sharding/SupervisedCounterCoordinator/singleton/coordinator] > Message [akka.cluster.sharding.ShardCoordinator$Internal$Register] from > Actor[akka://ClusterSystem/system/sharding/SupervisedCounter#-836215563] to > Actor[akka://ClusterSystem/system/sharding/SupervisedCounterCoordinator/singleton/coordinator] > was not delivered. [2] dead letters encountered. This logging can be turned > off or adjusted with configuration settings 'akka.log-dead-letters' and > 'akka.log-dead-letters-during-shutdown'. > SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder". > SLF4J: Defaulting to no-operation (NOP) logger implementation > SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further > details. > updating ################### > updating ################### > [ERROR] [11/11/2015 21:53:26.236] > [ClusterSystem-akka.actor.default-dispatcher-16] > [akka://ClusterSystem/system/sharding/Counter/23/123] Intentional Error > @@@@@@@@@@@@@@@@@@@@@@@@ > java.lang.RuntimeException: Intentional Error @@@@@@@@@@@@@@@@@@@@@@@@ > at > akka.cluster.sharding.ClusterShardingTest$Counter.updateState(ClusterShardingTest.java:160) > at > akka.cluster.sharding.ClusterShardingTest$Counter$1.apply(ClusterShardingTest.java:181) > at > akka.cluster.sharding.ClusterShardingTest$Counter$1.apply(ClusterShardingTest.java:179) > at > akka.persistence.UntypedPersistentActor$$anonfun$persist$1.apply(PersistentActor.scala:149) > at > akka.persistence.UntypedPersistentActor$$anonfun$persist$1.apply(PersistentActor.scala:149) > at > akka.persistence.Eventsourced$class.akka$persistence$Eventsourced$$peekApplyHandler(Eventsourced.scala:529) > at > akka.persistence.Eventsourced$ProcessingState$$anonfun$2.applyOrElse(Eventsourced.scala:549) > at > scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) > at > akka.persistence.Eventsourced$$anon$2.stateReceive(Eventsourced.scala:625) > at > akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:158) > at > akka.persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111) > at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525) > at akka.actor.ActorCell.invoke(ActorCell.scala:494) > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257) > at akka.dispatch.Mailbox.run(Mailbox.scala:224) > at akka.dispatch.Mailbox.exec(Mailbox.scala:234) > at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > [ERROR] [11/11/2015 21:53:26.236] > [ClusterSystem-akka.actor.default-dispatcher-22] > [akka://ClusterSystem/system/sharding/Counter/24/124] Intentional Error > @@@@@@@@@@@@@@@@@@@@@@@@ > java.lang.RuntimeException: Intentional Error @@@@@@@@@@@@@@@@@@@@@@@@ > at > akka.cluster.sharding.ClusterShardingTest$Counter.updateState(ClusterShardingTest.java:160) > at > akka.cluster.sharding.ClusterShardingTest$Counter$1.apply(ClusterShardingTest.java:181) > at > akka.cluster.sharding.ClusterShardingTest$Counter$1.apply(ClusterShardingTest.java:179) > at > akka.persistence.UntypedPersistentActor$$anonfun$persist$1.apply(PersistentActor.scala:149) > at > akka.persistence.UntypedPersistentActor$$anonfun$persist$1.apply(PersistentActor.scala:149) > at > akka.persistence.Eventsourced$class.akka$persistence$Eventsourced$$peekApplyHandler(Eventsourced.scala:529) > at > akka.persistence.Eventsourced$ProcessingState$$anonfun$2.applyOrElse(Eventsourced.scala:549) > at > scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) > at > akka.persistence.Eventsourced$$anon$2.stateReceive(Eventsourced.scala:625) > at > akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:158) > at > akka.persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111) > at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525) > at akka.actor.ActorCell.invoke(ActorCell.scala:494) > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257) > at akka.dispatch.Mailbox.run(Mailbox.scala:224) > at akka.dispatch.Mailbox.exec(Mailbox.scala:234) > at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > updating ################### > updating ################### > [ERROR] [11/11/2015 21:53:26.261] > [ClusterSystem-akka.actor.default-dispatcher-16] [akka.tcp:// > [email protected]:2550/system/sharding/Counter/23/123] Exception in > receiveRecover when replaying event type > [akka.cluster.sharding.ClusterShardingTest$Counter$CounterChanged] with > sequence number [1] for persistenceId [Counter-123]. > java.lang.RuntimeException: Intentional Error @@@@@@@@@@@@@@@@@@@@@@@@ > at > akka.cluster.sharding.ClusterShardingTest$Counter.updateState(ClusterShardingTest.java:160) > at > akka.cluster.sharding.ClusterShardingTest$Counter.onReceiveRecover(ClusterShardingTest.java:168) > at > akka.persistence.UntypedPersistentActor$$anonfun$receiveRecover$1.applyOrElse(PersistentActor.scala:116) > at > scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) > at > akka.persistence.Eventsourced$$anon$3$$anonfun$1.applyOrElse(Eventsourced.scala:438) > at akka.actor.Actor$class.aroundReceive(Actor.scala:480) > at > akka.persistence.UntypedPersistentActor.akka$persistence$Eventsourced$$super$aroundReceive(PersistentActor.scala:111) > at > akka.persistence.Eventsourced$$anon$4.stateReceive(Eventsourced.scala:481) > at > akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:158) > at > akka.persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111) > at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525) > at akka.actor.ActorCell.invoke(ActorCell.scala:494) > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257) > at akka.dispatch.Mailbox.run(Mailbox.scala:224) > at akka.dispatch.Mailbox.exec(Mailbox.scala:234) > at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > [ERROR] [11/11/2015 21:53:26.261] > [ClusterSystem-akka.actor.default-dispatcher-29] [akka.tcp:// > [email protected]:2550/system/sharding/Counter/24/124] Exception in > receiveRecover when replaying event type > [akka.cluster.sharding.ClusterShardingTest$Counter$CounterChanged] with > sequence number [1] for persistenceId [Counter-124]. > java.lang.RuntimeException: Intentional Error @@@@@@@@@@@@@@@@@@@@@@@@ > at > akka.cluster.sharding.ClusterShardingTest$Counter.updateState(ClusterShardingTest.java:160) > at > akka.cluster.sharding.ClusterShardingTest$Counter.onReceiveRecover(ClusterShardingTest.java:168) > at > akka.persistence.UntypedPersistentActor$$anonfun$receiveRecover$1.applyOrElse(PersistentActor.scala:116) > at > scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) > at > akka.persistence.Eventsourced$$anon$3$$anonfun$1.applyOrElse(Eventsourced.scala:438) > at akka.actor.Actor$class.aroundReceive(Actor.scala:480) > at > akka.persistence.UntypedPersistentActor.akka$persistence$Eventsourced$$super$aroundReceive(PersistentActor.scala:111) > at > akka.persistence.Eventsourced$$anon$4.stateReceive(Eventsourced.scala:481) > at > akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:158) > at > akka.persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111) > at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525) > at akka.actor.ActorCell.invoke(ActorCell.scala:494) > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257) > at akka.dispatch.Mailbox.run(Mailbox.scala:224) > at akka.dispatch.Mailbox.exec(Mailbox.scala:234) > at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > [INFO] [11/11/2015 21:53:26.263] > [ClusterSystem-akka.actor.default-dispatcher-21] > [akka://ClusterSystem/system/sharding/Counter/23/123] Message > [akka.persistence.JournalProtocol$WriteMessagesSuccessful$] from > Actor[akka://ClusterSystem/system/cassandra-journal#1254367220] to > Actor[akka://ClusterSystem/system/sharding/Counter/23/123#-1571818075] was > not delivered. [3] dead letters encountered. This logging can be turned off > or adjusted with configuration settings 'akka.log-dead-letters' and > 'akka.log-dead-letters-during-shutdown'. > [INFO] [11/11/2015 21:53:26.263] > [ClusterSystem-akka.actor.default-dispatcher-21] > [akka://ClusterSystem/system/sharding/Counter/24/124] Message > [akka.persistence.JournalProtocol$WriteMessagesSuccessful$] from > Actor[akka://ClusterSystem/system/cassandra-journal#1254367220] to > Actor[akka://ClusterSystem/system/sharding/Counter/24/124#-205995186] was > not delivered. [4] dead letters encountered. This logging can be turned off > or adjusted with configuration settings 'akka.log-dead-letters' and > 'akka.log-dead-letters-during-shutdown'. > updating ################### > updating ################### > [ERROR] [11/11/2015 21:53:36.300] > [ClusterSystem-akka.actor.default-dispatcher-18] [akka.tcp:// > [email protected]:2550/system/sharding/Counter/23/123] Exception in > receiveRecover when replaying event type > [akka.cluster.sharding.ClusterShardingTest$Counter$CounterChanged] with > sequence number [1] for persistenceId [Counter-123]. > java.lang.RuntimeException: Intentional Error @@@@@@@@@@@@@@@@@@@@@@@@ > at > akka.cluster.sharding.ClusterShardingTest$Counter.updateState(ClusterShardingTest.java:160) > at > akka.cluster.sharding.ClusterShardingTest$Counter.onReceiveRecover(ClusterShardingTest.java:168) > at > akka.persistence.UntypedPersistentActor$$anonfun$receiveRecover$1.applyOrElse(PersistentActor.scala:116) > at > scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) > at > akka.persistence.Eventsourced$$anon$3$$anonfun$1.applyOrElse(Eventsourced.scala:438) > at akka.actor.Actor$class.aroundReceive(Actor.scala:480) > at > akka.persistence.UntypedPersistentActor.akka$persistence$Eventsourced$$super$aroundReceive(PersistentActor.scala:111) > at > akka.persistence.Eventsourced$$anon$4.stateReceive(Eventsourced.scala:481) > at > akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:158) > at > akka.persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111) > at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525) > at akka.actor.ActorCell.invoke(ActorCell.scala:494) > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257) > at akka.dispatch.Mailbox.run(Mailbox.scala:224) > at akka.dispatch.Mailbox.exec(Mailbox.scala:234) > at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > [ERROR] [11/11/2015 21:53:36.300] > [ClusterSystem-akka.actor.default-dispatcher-32] [akka.tcp:// > [email protected]:2550/system/sharding/Counter/24/124] Exception in > receiveRecover when replaying event type > [akka.cluster.sharding.ClusterShardingTest$Counter$CounterChanged] with > sequence number [1] for persistenceId [Counter-124]. > java.lang.RuntimeException: Intentional Error @@@@@@@@@@@@@@@@@@@@@@@@ > at > akka.cluster.sharding.ClusterShardingTest$Counter.updateState(ClusterShardingTest.java:160) > at > akka.cluster.sharding.ClusterShardingTest$Counter.onReceiveRecover(ClusterShardingTest.java:168) > at > akka.persistence.UntypedPersistentActor$$anonfun$receiveRecover$1.applyOrElse(PersistentActor.scala:116) > at > scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) > at > akka.persistence.Eventsourced$$anon$3$$anonfun$1.applyOrElse(Eventsourced.scala:438) > at akka.actor.Actor$class.aroundReceive(Actor.scala:480) > at > akka.persistence.UntypedPersistentActor.akka$persistence$Eventsourced$$super$aroundReceive(PersistentActor.scala:111) > at > akka.persistence.Eventsourced$$anon$4.stateReceive(Eventsourced.scala:481) > at > akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:158) > at > akka.persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111) > at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525) > at akka.actor.ActorCell.invoke(ActorCell.scala:494) > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257) > at akka.dispatch.Mailbox.run(Mailbox.scala:224) > at akka.dispatch.Mailbox.exec(Mailbox.scala:234) > at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > > Process finished with exit code -1 > > -- > >>>>>>>>>> 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 [email protected]. > To post to this group, send email to [email protected]. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Typesafe <http://typesafe.com/> - Reactive apps on the JVM Twitter: @patriknw -- >>>>>>>>>> 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 [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
