akka.cluster.zookeeper

AkkaZkClient

class AkkaZkClient extends ZkClient

ZooKeeper client. Holds the ZooKeeper connection and manages its session.

Annotations
@deprecated
Deprecated

(Since version 2.0.2) ZooKeeperBasedMailbox will be removed in Akka 2.1

Linear Supertypes
ZkClient, Watcher, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. AkkaZkClient
  2. ZkClient
  3. Watcher
  4. AnyRef
  5. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new AkkaZkClient(zkServers: String, sessionTimeout: Duration, connectionTimeout: Duration, zkSerializer: ZkSerializer = ...)

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. def clone(): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  8. def close(): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws()
  9. def connect(arg0: Long, arg1: Watcher): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws()
  10. def connection: ZkConnection

  11. def countChildren(arg0: String): Int

    Definition Classes
    ZkClient
  12. def create(arg0: String, arg1: Any, arg2: CreateMode): String

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()
  13. def createEphemeral(arg0: String, arg1: Any): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()
  14. def createEphemeral(arg0: String): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()
  15. def createEphemeralSequential(arg0: String, arg1: Any): String

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()
  16. def createPersistent(arg0: String, arg1: Any): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()
  17. def createPersistent(arg0: String, arg1: Boolean): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()
  18. def createPersistent(arg0: String): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()
  19. def createPersistentSequential(arg0: String, arg1: Any): String

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()
  20. def delete(arg0: String): Boolean

    Definition Classes
    ZkClient
  21. def deleteRecursive(arg0: String): Boolean

    Definition Classes
    ZkClient
  22. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  23. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  24. def exists(arg0: String): Boolean

    Definition Classes
    ZkClient
  25. def exists(arg0: String, arg1: Boolean): Boolean

    Attributes
    protected[zkclient]
    Definition Classes
    ZkClient
  26. def finalize(): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  27. def getChildren(arg0: String, arg1: Boolean): List[String]

    Attributes
    protected[zkclient]
    Definition Classes
    ZkClient
  28. def getChildren(arg0: String): List[String]

    Definition Classes
    ZkClient
  29. final def getClass(): java.lang.Class[_]

    Definition Classes
    AnyRef → Any
  30. def getCreationTime(arg0: String): Long

    Definition Classes
    ZkClient
  31. def getDataListener(arg0: String): Set[IZkDataListener]

    Attributes
    protected[zkclient]
    Definition Classes
    ZkClient
  32. def getEventLock(): ZkLock

    Definition Classes
    ZkClient
  33. def getShutdownTrigger(): Boolean

    Definition Classes
    ZkClient
  34. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  35. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  36. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  37. final def notify(): Unit

    Definition Classes
    AnyRef
  38. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  39. def numberOfListeners(): Int

    Definition Classes
    ZkClient
  40. def process(arg0: WatchedEvent): Unit

    Definition Classes
    ZkClient → Watcher
  41. def readData[T](arg0: String, arg1: Stat, arg2: Boolean): T

    Attributes
    protected[zkclient]
    Definition Classes
    ZkClient
  42. def readData[T](arg0: String, arg1: Stat): T

    Definition Classes
    ZkClient
  43. def readData[T](arg0: String, arg1: Boolean): T

    Definition Classes
    ZkClient
  44. def readData[T](arg0: String): T

    Definition Classes
    ZkClient
  45. def reconnect(): Unit

  46. def retryUntilConnected[T](arg0: Callable[T]): T

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()
  47. def setCurrentState(arg0: KeeperState): Unit

    Definition Classes
    ZkClient
  48. def setShutdownTrigger(arg0: Boolean): Unit

    Definition Classes
    ZkClient
  49. def setZkSerializer(arg0: ZkSerializer): Unit

    Definition Classes
    ZkClient
  50. def showFolders(arg0: OutputStream): Unit

    Definition Classes
    ZkClient
  51. def subscribeChildChanges(arg0: String, arg1: IZkChildListener): List[String]

    Definition Classes
    ZkClient
  52. def subscribeDataChanges(arg0: String, arg1: IZkDataListener): Unit

    Definition Classes
    ZkClient
  53. def subscribeStateChanges(arg0: IZkStateListener): Unit

    Definition Classes
    ZkClient
  54. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  55. def toString(): String

    Definition Classes
    AnyRef → Any
  56. def unsubscribeAll(): Unit

    Definition Classes
    ZkClient
  57. def unsubscribeChildChanges(arg0: String, arg1: IZkChildListener): Unit

    Definition Classes
    ZkClient
  58. def unsubscribeDataChanges(arg0: String, arg1: IZkDataListener): Unit

    Definition Classes
    ZkClient
  59. def unsubscribeStateChanges(arg0: IZkStateListener): Unit

    Definition Classes
    ZkClient
  60. def updateDataSerialized[T](arg0: String, arg1: DataUpdater[T]): Unit

    Definition Classes
    ZkClient
  61. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  62. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  63. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  64. def waitForKeeperState(arg0: KeeperState, arg1: Long, arg2: TimeUnit): Boolean

    Definition Classes
    ZkClient
    Annotations
    @throws()
  65. def waitUntilConnected(arg0: Long, arg1: TimeUnit): Boolean

    Definition Classes
    ZkClient
    Annotations
    @throws()
  66. def waitUntilConnected(): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws()
  67. def waitUntilExists(arg0: String, arg1: TimeUnit, arg2: Long): Boolean

    Definition Classes
    ZkClient
    Annotations
    @throws()
  68. def watchForChilds(arg0: String): List[String]

    Definition Classes
    ZkClient
  69. def watchForData(arg0: String): Unit

    Definition Classes
    ZkClient
  70. def writeData(arg0: String, arg1: Any, arg2: Int): Unit

    Definition Classes
    ZkClient
  71. def writeData(arg0: String, arg1: Any): Unit

    Definition Classes
    ZkClient

Inherited from ZkClient

Inherited from Watcher

Inherited from AnyRef

Inherited from Any