Module swim.io.mqtt
Package swim.io.mqtt

Interface MqttSocket<I,O>

All Known Implementing Classes:
AbstractMqttSocket
public interface MqttSocket<I,O>

  • Method Details

    • mqttSocketContext

      MqttSocketContext<I,O> mqttSocketContext()

    • setMqttSocketContext

      void setMqttSocketContext(MqttSocketContext<I,O> context)

    • idleTimeout

      long idleTimeout()

    • doRead

      void doRead()

    • didRead

      void didRead(MqttPacket<? extends I> packet)

    • doWrite

      void doWrite()

    • didWrite

      void didWrite(MqttPacket<? extends O> packet)

    • willConnect

      void willConnect()

    • didConnect

      void didConnect()

    • willSecure

      void willSecure()

    • didSecure

      void didSecure()

    • willBecome

      void willBecome(IpSocket socket)

    • didBecome

      void didBecome(IpSocket socket)

    • didTimeout

      void didTimeout()

    • didDisconnect

      void didDisconnect()

    • didFail

      void didFail(Throwable error)