These are chat archives for paypal/squbs

27th
Jul 2018
Corey Auger
@coreyauger
Jul 27 17:26
hey guys.. having trouble running the CustomRouteTestKit with a cluster
i have tried to pass in a config like this
squbs {
  # Name of the actor system for squbs to create.
  actorsystem-name = "io-surfkit-nubank-HttpServiceSpec"
}

akka {
  loglevel = DEBUG
  loggers = ["akka.event.slf4j.Slf4jLogger"]
  logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"

  extensions = ["akka.cluster.pubsub.DistributedPubSub"]

  http{
    server {
      # The time after which an idle connection will be automatically closed.
      # Set to `infinite` to completely disable idle connection timeouts.
      idle-timeout = infinite

      # Socket options to set for the listening socket. If a setting is left
      # undefined, it will use whatever the default on the system is.
      socket-options {
        so-receive-buffer-size = undefined
        so-send-buffer-size = undefined
        so-reuse-address = undefined
        so-traffic-class = undefined
        tcp-keep-alive = true
        tcp-oob-inline = undefined
        tcp-no-delay = undefined
      }
    }
  }

  actor {
    provider = "akka.cluster.ClusterActorRefProvider"
    mailbox.requirements{
      "akka.dispatch.BoundedMessageQueueSemantics" = bounded-mailbox
    }
  }

  remote {
    log-remote-lifecycle-events = on
    netty.tcp {
      hostname = "192.168.200.246"      # external (logical) hostname
      port = 3551               # external (logical) port

      bind-hostname = 0.0.0.0
      bind-port = 3551
      maximum-frame-size = 512 KiB
    }
  }


  persistence {
    journal {
      plugin = "dummy-journal"

      dummy-journal {
        class = "org.dmonix.akka.persistence.JournalPlugin"
        plugin-dispatcher = "akka.actor.default-dispatcher"
      }
    }
  }

  cluster {
    # You would have more seed nodes defined here..
    seed-nodes = [
      "akka.tcp://io-surfkit-nubank-HttpServiceSpec@192.168.200.246:3551"]

    # auto downing is NOT safe for production deployments.
    # you may want to use it during development, read more about it in the docs.
    #
     auto-down-unreachable-after = 10s
  }
}
Anil Gursel
@anilgursel
Jul 27 17:28
Never tried running CustomRouteTestKit with a cluster :(
Corey Auger
@coreyauger
Jul 27 17:28
yea ok..
problem is here:
10:29:19.447 [io-surfkit-nubank-HttpServiceSpec-akka.actor.default-dispatcher-16] ERROR akka.remote.EndpointWriter - dropping message [class akka.actor.ActorSelectionMessage] for non-local recipient [Actor[akka.tcp://squbs@192.168.200.246:2551/]] arriving at [akka.tcp://squbs@192.168.200.246:2551] inbound addresses are [akka.tcp://io-surfkit-nubank-HttpServiceSpec@192.168.200.246:2551]
10:29:24.464 [io-surfkit-nubank-HttpServiceSpec-akka.actor.default-dispatcher-16] WARN akka.cluster.JoinSeedNodeProcess - Couldn't join seed nodes after [2] attempts, will try again. seed-nodes=[akka.tcp://squbs@192.168.200.246:2551]
10:29:24.468 [io-surfkit-nubank-HttpServiceSpec-akka.actor.default-dispatcher-16] ERROR akka.remote.EndpointWriter - dropping message [class akka.actor.ActorSelectionMessage] for non-local recipient [Actor[akka.tcp://squbs@192.168.200.246:2551/]] arriving at [akka.tcp://squbs@192.168.200.246:2551] inbound addresses are [akka.tcp://io-surfkit-nubank-HttpServiceSpec@192.168.200.246:2551]
so it seems to want to use the squbs actor system still somewhere
If anyone has any idea that would be a big help.. thanks :)
@anilgursel thanks anyways :)