Packages

final class MqttSessionSettings extends AnyRef

Configuration settings for client and server usage.

Source
MqttSessionSettings.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MqttSessionSettings
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

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. val clientSendBufferSize: Int
  6. val clientTerminationWatcherBufferSize: Int
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  8. val commandParallelism: Int
  9. val consumerPubAckRecTimeout: FiniteDuration
  10. val consumerPubCompTimeout: FiniteDuration
  11. val consumerPubRelTimeout: FiniteDuration
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  14. val eventParallelism: Int
  15. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  16. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  17. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  19. val maxPacketSize: Int
  20. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  21. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  22. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  23. val producerPubAckRecTimeout: FiniteDuration
  24. val producerPubCompTimeout: FiniteDuration
  25. val receiveConnAckTimeout: FiniteDuration
  26. val receiveConnectTimeout: FiniteDuration
  27. val receiveSubAckTimeout: FiniteDuration
  28. val receiveUnsubAckTimeout: FiniteDuration
  29. val serverSendBufferSize: Int
  30. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  31. def toString(): String
    Definition Classes
    MqttSessionSettings → AnyRef → Any
  32. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  33. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  34. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  35. def withClientSendBufferSize(clientSendBufferSize: Int): MqttSessionSettings

    Just for clients - the number of commands that can be buffered while connected to a server.

    Just for clients - the number of commands that can be buffered while connected to a server. Defaults to 10. Any commands received beyond this will apply backpressure.

  36. def withClientTerminationWatcherBufferSize(clientTerminationWatcherBufferSize: Int): MqttSessionSettings

    The maximum number of client termination event observers permitted.

    The maximum number of client termination event observers permitted. Defaults to 100 which should be more than adequate for most situations.

  37. def withCommandParallelism(commandParallelism: Int): MqttSessionSettings

    The number of commands that can be processed at a time, with a default of 50.

    The number of commands that can be processed at a time, with a default of 50. For client usage, note that each CONNECT will reduced the availability of remaining command channels for other commands by 1. For server usage, each CONNACK received will reduce the availability of remaining command channels for other commands by 1.

  38. def withConsumerPubAckRecTimeout(consumerPubAckRecTimeout: Duration): MqttSessionSettings

    JAVA API

    JAVA API

    For consumers of PUBLISH, the amount of time to wait before receiving an ack/receive command locally in reply to a QoS 1/2 publish event before failing. Defaults to 30 seconds.

  39. def withConsumerPubAckRecTimeout(consumerPubAckRecTimeout: FiniteDuration): MqttSessionSettings

    For consumers of PUBLISH, the amount of time to wait before receiving an ack/receive command locally in reply to a QoS 1/2 publish event before failing.

    For consumers of PUBLISH, the amount of time to wait before receiving an ack/receive command locally in reply to a QoS 1/2 publish event before failing. Defaults to 30 seconds.

  40. def withConsumerPubCompTimeout(consumerPubCompTimeout: Duration): MqttSessionSettings

    JAVA API

    JAVA API

    For consumers of PUBLISH, the amount of time to wait before receiving a complete command locally in reply to a QoS 2 publish event before failing. Defaults to 30 seconds.

  41. def withConsumerPubCompTimeout(consumerPubCompTimeout: FiniteDuration): MqttSessionSettings

    For consumers of PUBLISH, the amount of time to wait before receiving a complete command locally in reply to a QoS 2 publish event before failing.

    For consumers of PUBLISH, the amount of time to wait before receiving a complete command locally in reply to a QoS 2 publish event before failing. Defaults to 30 seconds.

  42. def withConsumerPubRelTimeout(consumerPubRelTimeout: Duration): MqttSessionSettings

    JAVA API

    JAVA API

    For consumers of PUBLISH, the amount of time to wait for a server to release a QoS 2 publish before failing. Defaults to 30 seconds.

  43. def withConsumerPubRelTimeout(consumerPubRelTimeout: FiniteDuration): MqttSessionSettings

    For consumers of PUBLISH, the amount of time to wait for a server to release a QoS 2 publish before failing.

    For consumers of PUBLISH, the amount of time to wait for a server to release a QoS 2 publish before failing. Defaults to 30 seconds.

  44. def withEventParallelism(eventParallelism: Int): MqttSessionSettings

    This is the number of events that can be received in parallel at any one time, with a default of 10.

  45. def withMaxPacketSize(maxPacketSize: Int): MqttSessionSettings

    The maximum size of a packet that is allowed to be decoded.

    The maximum size of a packet that is allowed to be decoded. Defaults to 4k.

  46. def withProducerPubAckRecTimeout(producerPubAckRecTimeout: Duration): MqttSessionSettings

    JAVA API

    JAVA API

    For producers of PUBLISH, the amount of time to wait to ack/receive a QoS 1/2 publish before retrying with the DUP flag set. Defaults to 0 seconds, which means republishing only occurs on reconnect.

  47. def withProducerPubAckRecTimeout(producerPubAckRecTimeout: FiniteDuration): MqttSessionSettings

    For producers of PUBLISH, the amount of time to wait to ack/receive a QoS 1/2 publish before retrying with the DUP flag set.

    For producers of PUBLISH, the amount of time to wait to ack/receive a QoS 1/2 publish before retrying with the DUP flag set. Defaults to 0 seconds, which means republishing only occurs on reconnect.

  48. def withProducerPubCompTimeout(producerPubCompTimeout: Duration): MqttSessionSettings

    JAVA API

    JAVA API

    For producers of PUBLISH, the amount of time to wait for a server to complete a QoS 2 publish before retrying with another PUBREL. Defaults to 0 seconds, which means republishing only occurs on reconnect.

  49. def withProducerPubCompTimeout(producerPubCompTimeout: FiniteDuration): MqttSessionSettings

    For producers of PUBLISH, the amount of time to wait for a server to complete a QoS 2 publish before retrying with another PUBREL.

    For producers of PUBLISH, the amount of time to wait for a server to complete a QoS 2 publish before retrying with another PUBREL. Defaults to 0 seconds, which means republishing only occurs on reconnect.

  50. def withReceiveConnAckTimeout(receiveConnAckTimeout: Duration): MqttSessionSettings

    JAVA API

    JAVA API

    For clients, the amount of time to wait for a server to ack a connection. For servers, the amount of time to wait before receiving an ack command locally in reply to a connect event. Defaults to 30 seconds.

  51. def withReceiveConnAckTimeout(receiveConnAckTimeout: FiniteDuration): MqttSessionSettings

    For clients, the amount of time to wait for a server to ack a connection.

    For clients, the amount of time to wait for a server to ack a connection. For servers, the amount of time to wait before receiving an ack command locally in reply to a connect event. Defaults to 30 seconds.

  52. def withReceiveConnectTimeout(receiveConnectTimeout: Duration): MqttSessionSettings

    JAVA API

    JAVA API

    For servers, the amount of time a session can be disconnected before being re-connected. Defaults to 5 minutes.

  53. def withReceiveConnectTimeout(receiveConnectTimeout: FiniteDuration): MqttSessionSettings

    For servers, the amount of time a session can be disconnected before being re-connected.

    For servers, the amount of time a session can be disconnected before being re-connected. Defaults to 5 minutes.

  54. def withReceiveSubAckTimeout(receiveSubAckTimeout: Duration): MqttSessionSettings

    JAVA API

    JAVA API

    For clients, the amount of time to wait for a server to ack a subscribe. For servers, the amount of time to wait before receiving an ack command locally in reply to a subscribe event. Defaults to 30 seconds.

  55. def withReceiveSubAckTimeout(receiveSubAckTimeout: FiniteDuration): MqttSessionSettings

    For clients, the amount of time to wait for a server to ack a subscribe.

    For clients, the amount of time to wait for a server to ack a subscribe. For servers, the amount of time to wait before receiving an ack command locally in reply to a subscribe event. Defaults to 30 seconds.

  56. def withReceiveUnsubAckTimeout(receiveUnsubAckTimeout: Duration): MqttSessionSettings

    JAVA API

    JAVA API

    For clients, the amount of time to wait for a server to ack a unsubscribe. For servers, the amount of time to wait before receiving an ack command locally in reply to a unsubscribe event. Defaults to 30 seconds.

  57. def withReceiveUnsubAckTimeout(receiveUnsubAckTimeout: FiniteDuration): MqttSessionSettings

    For clients, the amount of time to wait for a server to ack a unsubscribe.

    For clients, the amount of time to wait for a server to ack a unsubscribe. For servers, the amount of time to wait before receiving an ack command locally in reply to a unsubscribe event. Defaults to 30 seconds.

  58. def withServerSendBufferSize(serverSendBufferSize: Int): MqttSessionSettings

    Just for servers - the number of commands that can be buffered while connected to a client.

    Just for servers - the number of commands that can be buffered while connected to a client. Defaults to 100. Any commands received beyond this will apply backpressure.

Inherited from AnyRef

Inherited from Any

Ungrouped