Package org.apache.pekko.remote.testkit

Class MultiNodeConfig

java.lang.Object
org.apache.pekko.remote.testkit.MultiNodeConfig
public abstract class MultiNodeConfig extends Object
Configure the role names and participants of the test, including configuration settings.

  • Constructor Summary

    Constructors
    Constructor
    Description
    MultiNodeConfig()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    commonConfig(com.typesafe.config.Config config)
    Register a common base config for all test participants, if so desired.
    com.typesafe.config.Config
    debugConfig(boolean on)
    Include for verbose debug logging
    void
    deployOn(RoleName role, String deployment)
     
    void
    deployOnAll(String deployment)
     
    void
    nodeConfig(scala.collection.immutable.Seq<RoleName> roles, scala.collection.immutable.Seq<com.typesafe.config.Config> configs)
    Register a config override for a specific participant.
    RoleName
    role(String name)
    Construct a RoleName and return it, to be used as an identifier in the test.
    void
    testTransport(boolean on)
    To be able to use blackhole, passThrough, and throttle you must activate the failure injector and throttler transport adapters by specifying testTransport(on = true) in your MultiNodeConfig.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • MultiNodeConfig

      public MultiNodeConfig()

  • Method Details

    • commonConfig

      public void commonConfig(com.typesafe.config.Config config)
      Register a common base config for all test participants, if so desired.

    • debugConfig

      public com.typesafe.config.Config debugConfig(boolean on)
      Include for verbose debug logging
      Parameters:
      on - when true debug Config is returned, otherwise config with info logging

    • deployOn

      public void deployOn(RoleName role, String deployment)

    • deployOnAll

      public void deployOnAll(String deployment)

    • nodeConfig

      public void nodeConfig(scala.collection.immutable.Seq<RoleName> roles, scala.collection.immutable.Seq<com.typesafe.config.Config> configs)
      Register a config override for a specific participant.

    • role

      public RoleName role(String name)
      Construct a RoleName and return it, to be used as an identifier in the test. Registration of a role name creates a role which then needs to be filled.

    • testTransport

      public void testTransport(boolean on)
      To be able to use blackhole, passThrough, and throttle you must activate the failure injector and throttler transport adapters by specifying testTransport(on = true) in your MultiNodeConfig.