Thanks for the update. /Patrik On Wed, Mar 25, 2015 at 3:52 AM, Paul Cleary <[email protected]> wrote:
> Answering my own question here, but I seem to have figured it out. > > Must have been a copy / paste error from the template into my project. > > Not sure exactly what it was, but I am up and running. > > > On Tuesday, March 24, 2015 at 4:43:03 PM UTC-4, Paul Cleary wrote: >> >> I am trying to run the cluster sharding example activator template >> project. >> >> It looks like everything starts up ok. >> >> But, then I am getting the following error: >> >>> Lookup of shared journal at akka.tcp://ClusterSystem@127. >>> 0.0.1:2551/user/store timed out >> >> >> >> I am using the code: >> https://github.com/typesafehub/activator-akka-cluster-sharding-scala, so >> most of the following is copy paste. >> >> >> Here is my config: >> >>> akka { >>> loglevel = INFO >>> actor { >>> provider = "akka.cluster.ClusterActorRefProvider" >>> } >>> remote { >>> log-remote-lifecycle-events = off >>> netty.tcp { >>> hostname = "127.0.0.1" >>> port = 0 >>> } >>> } >>> cluster { >>> seed-nodes = [ >>> "akka.tcp://[email protected]:2551", >>> "akka.tcp://[email protected]:2552"] >>> auto-down-unreachable-after = 10s >>> } >>> extensions = ["akka.contrib.pattern.ClusterReceptionistExtension"] >>> persistence { >>> journal.plugin = "akka.persistence.journal.leveldb-shared" >>> journal.leveldb-shared.store { >>> # DO NOT USE 'native = off' IN PRODUCTION !!! >>> native = off >>> dir = "target/shared-journal" >>> } >>> snapshot-store.local.dir = "target/snapshots" >>> } >>> } >> >> >> And the source code: >> >> def startupSharedJournal(system: ActorSystem, startStore: Boolean, >>> path: ActorPath): Unit = { >>> // Start the shared journal one one node (don't crash this SPOF) >>> // This will not be needed with a distributed journal >>> if (startStore) >>> system.actorOf(Props[SharedLeveldbStore], "store") >>> // register the shared journal >>> import system.dispatcher >>> implicit val timeout = Timeout(15.seconds) >>> val f = (system.actorSelection(path) ? Identify(None)) >>> f.onSuccess { >>> case ActorIdentity(_, Some(ref)) => SharedLeveldbJournal.setStore(ref, >>> system) >>> case _ => >>> system.log.error("Shared journal not started at {}", path) >>> system.shutdown() >>> } >>> f.onFailure { >>> case _ => >>> system.log.error("Lookup of shared journal at {} timed out", >>> path) >>> system.shutdown() >>> } >>> } >> >> >> >> >> -- > >>>>>>>>>> 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.
