Packages

class MqttServer extends AnyRef

An MQTT server

You can accept incoming MQTT connection requests providing a io.vertx.scala.mqtt.MqttServer#endpointHandler. As the requests arrive, the handler will be called with an instance of io.vertx.scala.mqtt.MqttEndpoint in order to manage the communication with the remote MQTT client.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MqttServer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MqttServer(_asJava: AnyRef)

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. def actualPort(): Int

    The actual port the server is listening on.

    The actual port the server is listening on. This is useful if you bound the server specifying 0 as port number signifying an ephemeral port * @return the actual port the server is listening on.

  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def asJava: AnyRef
  7. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  8. def close(completionHandler: Handler[AsyncResult[Unit]]): Unit

    Close the server supplying an handler that will be called when the server is actually closed (or has failed).

    Close the server supplying an handler that will be called when the server is actually closed (or has failed). * @param completionHandler the handler called on completion

  9. def close(): Unit

    Close the server.

    Close the server.

    The close happens asynchronously and the server may not be closed until some time after the call has returned.

  10. def closeFuture(): Future[Unit]

    Like close but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  11. def endpointHandler(handler: Handler[MqttEndpoint]): MqttServer

    Set the endpoint handler for the server.

    Set the endpoint handler for the server. If an MQTT client connect to the server a new MqttEndpoint instance will be created and passed to the handler * @param handler the endpoint handler

    returns

    a reference to this, so the API can be used fluently

  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  14. def exceptionHandler(handler: Handler[Throwable]): MqttServer

    Set an exception handler for the server, that will be called when an error happens independantly of an accepted io.vertx.scala.mqtt.MqttEndpoint, like a rejected connection * @param handler the exception handler

    Set an exception handler for the server, that will be called when an error happens independantly of an accepted io.vertx.scala.mqtt.MqttEndpoint, like a rejected connection * @param handler the exception handler

    returns

    a reference to this, so the API can be used fluently

  15. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  16. final def getClass(): Class[_]
    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. def listen(listenHandler: Handler[AsyncResult[MqttServer]]): MqttServer

    Start the server listening for incoming connections using the specified options through the constructor * @param listenHandler handler called when the asynchronous listen call ends

    Start the server listening for incoming connections using the specified options through the constructor * @param listenHandler handler called when the asynchronous listen call ends

    returns

    a reference to this, so the API can be used fluently

  20. def listen(port: Int, listenHandler: Handler[AsyncResult[MqttServer]]): MqttServer

    Start the server listening for incoming connections on the port specified but on "0.0.0.0" as host.

    Start the server listening for incoming connections on the port specified but on "0.0.0.0" as host. It ignores any options specified through the constructor * @param port the port to listen on

    listenHandler

    handler called when the asynchronous listen call ends

    returns

    a reference to this, so the API can be used fluently

  21. def listen(port: Int): MqttServer

    Start the server listening for incoming connections on the port specified but on "0.0.0.0" as host.

    Start the server listening for incoming connections on the port specified but on "0.0.0.0" as host. It ignores any options specified through the constructor * @param port the port to listen on

    returns

    a reference to this, so the API can be used fluently

  22. def listen(port: Int, host: String, listenHandler: Handler[AsyncResult[MqttServer]]): MqttServer

    Start the server listening for incoming connections on the port and host specified It ignores any options specified through the constructor * @param port the port to listen on

    Start the server listening for incoming connections on the port and host specified It ignores any options specified through the constructor * @param port the port to listen on

    host

    the host to listen on

    listenHandler

    handler called when the asynchronous listen call ends

    returns

    a reference to this, so the API can be used fluently

  23. def listen(port: Int, host: String): MqttServer

    Start the server listening for incoming connections on the port and host specified * @param port the port to listen on

    Start the server listening for incoming connections on the port and host specified * @param port the port to listen on

    host

    the host to listen on

    returns

    a reference to this, so the API can be used fluently

  24. def listen(): MqttServer

    Start the server listening for incoming connections using the specified options through the constructor * @return a reference to this, so the API can be used fluently

  25. def listenFuture(): Future[MqttServer]

    Like listen but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  26. def listenFuture(port: Int): Future[MqttServer]

    Like listen but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  27. def listenFuture(port: Int, host: String): Future[MqttServer]

    Like listen but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  28. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  29. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  30. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  31. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  32. def toString(): String
    Definition Classes
    AnyRef → Any
  33. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  34. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  35. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped