pubsub-factory-test.conf

akka {
  actor {
    provider = "cluster"
    enable-additional-serialization-bindings = on
    serializers {
      json = "org.eclipse.ditto.internal.utils.cluster.JsonJsonifiableSerializer"
    }
    serialization-bindings {
      "org.eclipse.ditto.base.model.json.Jsonifiable" = json
    }
  }

  remote {
    artery {
      enabled = on
      transport = tcp
      canonical {
        hostname = "127.0.0.1"
        port = 0
      }
      advanced {
        idle-cpu-level = 1 # low throughput for development
      }
    }
  }

  cluster {
    seed-nodes = []
    metrics.enabled = "off"
    jmx.multi-mbeans-in-same-jvm = "on"
  }

  test {
    timefactor = 1.0
  }
}

ditto {
  mapping-strategy.implementation = "org.eclipse.ditto.internal.utils.pubsub.TestMappingStrategies"
  pubsub {
    restart-delay = 1s
    update-interval = 100ms // increase this value to simulate slow systems
    reset-probability = 0.0 // reset is not mocked for the tests
    seed = "dummy-seed"
  }

  ddata {
    number-of-shards = 5
  }
}
akka.cluster.distributed-data {
  gossip-interval = 100ms
  notify-subscribers-interval = 100ms
}