Packages

class ClusterEnvironment extends AnyRef

All configuration options related to a cluster environment, along with some long-lived resources including a thread-pool.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ClusterEnvironment
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ClusterEnvironment(builder: Builder)

Value Members

  1. def core: CoreEnvironment

    Returns the underlying (Java) core-io CoreEnvironment that is built from this.

    Returns the underlying (Java) core-io CoreEnvironment that is built from this.

    Provides access to, amongst other things, the event bus.

  2. def shutdown(timeout: Duration = ...): Unit

    Shuts this environment down.

    Shuts this environment down. If the application created this (i.e. rather than using one of the convenience Cluster.create methods, then it is responsible for calling shutdown on it.

    This will block until everything is shutdown, or the timeout is exceeded.

    Note that once shutdown, the environment cannot be restarted so it is advised to perform this operation at the very last operation in the SDK shutdown process.

    timeout

    the timeout to wait maximum.

  3. def shutdownReactive(timeout: Duration = ...): SMono[Unit]