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.