SessionManager

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 buildConnectRequest(sessionTimeout: Duration): ConnectRequest

   Build a connect request to create a new session

   Build a connect request to create a new session

   returns

   a customized ConnectResponse

8. def buildReconnectRequest(sessionTimeout: Option[Duration] = None): ConnectRequest

   Build a reconnect request depending if RO mode is allowed by user, and if current session has a fake session ID ( never connected to RW server)

   Build a reconnect request depending if RO mode is allowed by user, and if current session has a fake session ID ( never connected to RW server)

   sessionTimeout

   an optional timeout for the session

   returns

   a customized ConnectResponse

9. def canCloseSession: Boolean

10. def canCreateSession: Boolean

11. def canReconnect: Boolean

12. def clone(): AnyRef

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

13. def closeAndClean(): Unit

    To close current session and clean session manager

14. final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

15. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

16. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

17. final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

18. def hashCode(): Int

    Definition Classes

    AnyRef → Any

19. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

20. final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

21. def newSession(conRep: ConnectResponse, sessionTimeout: Duration, pinger: () ⇒ Future[Unit]): Unit

    Used to create a fresh new Session from the connect response.

    Used to create a fresh new Session from the connect response. Use cases : connection, reconnection with new Session

    conRep

    connect Response

    sessionTimeout

    connect request session timeout

    pinger

    function to send ping request

    returns

    Unit

22. final def notify(): Unit

    Definition Classes

    AnyRef

23. final def notifyAll(): Unit

    Definition Classes

    AnyRef

24. def parseHeader(header: ReplyHeader): Unit

    Here we are parsing the header's error field and changing the connection state if required then the ZXID is updated.

    Here we are parsing the header's error field and changing the connection state if required then the ZXID is updated.

    header

    request's header

25. def parseWatchEvent(event: WatchEvent): Unit

    Here we are parsing the watchEvent's state field and changing the connection state if required

    Here we are parsing the watchEvent's state field and changing the connection state if required

    event

    a request header

26. def reinit(conReq: ConnectResponse, pinger: () ⇒ Future[Unit]): Try[Unit]

    Used to reconnect with the same session Ids Use cases : session reconnection after connection loss, reconnection to RW mode server.

    Used to reconnect with the same session Ids Use cases : session reconnection after connection loss, reconnection to RW mode server.

    conReq

    connect response

    pinger

    function to send ping request

    returns

    Try[Unit]

27. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

28. def toString(): String

    Definition Classes

    AnyRef → Any

29. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

30. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

31. final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )