Class MqttSubscribeMessage

java.lang.Object
io.vertx.mutiny.mqtt.messages.MqttSubscribeMessage
All Implemented Interfaces:
MutinyDelegate, MqttMessage

public class MqttSubscribeMessage extends Object implements MqttMessage, MutinyDelegate
Represents an MQTT SUBSCRIBE message

NOTE: This class has been automatically generated from the original non Mutiny-ified interface.

See Also:
  • MqttSubscribeMessage
  • Field Details

  • Constructor Details

    • MqttSubscribeMessage

      public MqttSubscribeMessage(io.vertx.mqtt.messages.MqttSubscribeMessage delegate)
      Create a new instance of MqttSubscribeMessage delegating to the given (non-null) instance of MqttSubscribeMessage.
    • MqttSubscribeMessage

      public MqttSubscribeMessage(Object delegate)
  • Method Details

    • getDelegate

      public io.vertx.mqtt.messages.MqttSubscribeMessage getDelegate()
      Get the delegate instance.

      This method returns the instance on which this shim is delegating the calls. And so, give you access to the bare API.

      Specified by:
      getDelegate in interface MqttMessage
      Specified by:
      getDelegate in interface MutinyDelegate
      Returns:
      the delegate instance
    • create

      public static MqttSubscribeMessage create(int messageId, List<io.netty.handler.codec.mqtt.MqttTopicSubscription> topicSubscriptions, io.netty.handler.codec.mqtt.MqttProperties properties)
      Create a concrete instance of a Vert.x subscribe message
      Parameters:
      messageId - message identifier
      topicSubscriptions - list with topics and related quality of service levels (from Netty)
      properties - MQTT message properties
      Returns:
      Vert.x subscribe message
    • topicSubscriptions

      public List<MqttTopicSubscription> topicSubscriptions()
      Returns:
      List with topics and related quolity of service levels
    • properties

      public io.netty.handler.codec.mqtt.MqttProperties properties()
      Returns:
      MQTT properties
    • messageId

      public int messageId()
      Specified by:
      messageId in interface MqttMessage
      Returns:
      Message identifier
    • newInstance

      public static MqttSubscribeMessage newInstance(io.vertx.mqtt.messages.MqttSubscribeMessage delegate)
      Creates a new instance of the MqttSubscribeMessage.
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • toString

      public String toString()
      Overrides:
      toString in class Object