Packages

c

eu.phisikus.plotka.framework.consul

ClusteredNetworkListener

class ClusteredNetworkListener extends NetworkListener

This is a NetworkListener implementation with additional consul-based node discovery capabilities. It registers as a service in the Consul on ListenerController.start() and unregisters on ListenerController.stop(). Additionally you can get a set of other available instances of the service by calling getPeers().

Linear Supertypes
NetworkListener, ListenerController, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ClusteredNetworkListener
  2. NetworkListener
  3. ListenerController
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ClusteredNetworkListener(nodeConfiguration: NodeConfiguration, messageConsumer: NetworkMessageConsumer, registryManager: ConsulServiceRegistryManager)

    nodeConfiguration

    initial configuration

    messageConsumer

    handler that will be called for each received message

    registryManager

    consul registry manager that will be used to register and unregister the service

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  9. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  10. def getPeers(): Set[NetworkPeer]

    Get information about active peers

    Get information about active peers

    returns

    set of NetworkPeer objects representing active peers

  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. val messageConsumer: NetworkMessageConsumer
    Definition Classes
    NetworkListener
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. val nodeConfiguration: NodeConfiguration
    Definition Classes
    NetworkListener
  16. final def notify(): Unit
    Definition Classes
    AnyRef
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  18. def start(): Unit
    Definition Classes
    ClusteredNetworkListener → NetworkListener → ListenerController
  19. def stop(): Unit
    Definition Classes
    ClusteredNetworkListener → NetworkListener → ListenerController
  20. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  21. def toString(): String
    Definition Classes
    AnyRef → Any
  22. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from NetworkListener

Inherited from ListenerController

Inherited from AnyRef

Inherited from Any

Ungrouped