Package io.smallrye.reactive.messaging.mqtt.server.i18n

Interface MqttServerLogging

  • All Superinterfaces:
    org.jboss.logging.BasicLogger
    All Known Implementing Classes:
    MqttServerLogging_$logger
    @MessageLogger(projectCode="SRMSG",
               length=5)
public interface MqttServerLogging
extends org.jboss.logging.BasicLogger
    Logging for MQTT Server Connector Assigned ID range is 17500-17599

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void clientDisconnected​(String clientIdentifier)  
      void closed()  
      void errorWithClient​(String clientIdentifier, Throwable t)  
      void exceptionThrown​(Throwable t)  
      void exceptionWhileClosing​(Throwable t)  
      void failedToStart​(Throwable t)  
      void newSubscriberAdded​(org.reactivestreams.Subscription subscription)  
      void pingReceived​(String clientIdentifier)  
      void receivedMessageFromClient​(io.vertx.mutiny.core.buffer.Buffer buffer, io.netty.handler.codec.mqtt.MqttQoS qos, String client)  
      void receivedSubscription​(io.vertx.mutiny.mqtt.messages.MqttSubscribeMessage message, String client)  
      void requestToConnect​(String clientIdentifier, boolean isClean)  
      void requestToConnectKeepAlive​(int s)  
      void requestToConnectUserName​(String user, String pass)  
      void requestToConnectWill​(String topic, byte[] msg, int qos, boolean retain)  
      void sendToClient​(String f, String client, int messageId)  
      void serverListeningOn​(String host, int port)  

      • Methods inherited from interface org.jboss.logging.BasicLogger

        debug, debug, debug, debug, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugv, debugv, debugv, debugv, debugv, debugv, debugv, debugv, error, error, error, error, errorf, errorf, errorf, errorf, errorf, errorf, errorf, errorf, errorv, errorv, errorv, errorv, errorv, errorv, errorv, errorv, fatal, fatal, fatal, fatal, fatalf, fatalf, fatalf, fatalf, fatalf, fatalf, fatalf, fatalf, fatalv, fatalv, fatalv, fatalv, fatalv, fatalv, fatalv, fatalv, info, info, info, info, infof, infof, infof, infof, infof, infof, infof, infof, infov, infov, infov, infov, infov, infov, infov, infov, isDebugEnabled, isEnabled, isInfoEnabled, isTraceEnabled, log, log, log, log, logf, logf, logf, logf, logf, logf, logf, logf, logf, logf, logf, logf, logv, logv, logv, logv, logv, logv, logv, logv, logv, logv, logv, logv, trace, trace, trace, trace, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracev, tracev, tracev, tracev, tracev, tracev, tracev, tracev, warn, warn, warn, warn, warnf, warnf, warnf, warnf, warnf, warnf, warnf, warnf, warnv, warnv, warnv, warnv, warnv, warnv, warnv, warnv

    • Method Detail

      • exceptionThrown

        @LogMessage(level=ERROR)
@Message(id=17500,
         value="Exception thrown")
void exceptionThrown​(@Cause
                     Throwable t)

      • requestToConnect

        @LogMessage(level=DEBUG)
@Message(id=17501,
         value="MQTT client [%s] request to connect, clean session = %s")
void requestToConnect​(String clientIdentifier,
                      boolean isClean)

      • requestToConnectUserName

        @LogMessage(level=TRACE)
@Message(id=17502,
         value="[username = %s, password = %s]")
void requestToConnectUserName​(String user,
                              String pass)

      • requestToConnectWill

        @LogMessage(level=TRACE)
@Message(id=17503,
         value="[will topic = %s msg = %s QoS = %s isRetain = %s]")
void requestToConnectWill​(String topic,
                          byte[] msg,
                          int qos,
                          boolean retain)

      • requestToConnectKeepAlive

        @LogMessage(level=TRACE)
@Message(id=17504,
         value="[keep alive timeout = %s]")
void requestToConnectKeepAlive​(int s)

      • errorWithClient

        @LogMessage(level=ERROR)
@Message(id=17505,
         value="Error with client %s")
void errorWithClient​(String clientIdentifier,
                     @Cause
                     Throwable t)

      • clientDisconnected

        @LogMessage(level=DEBUG)
@Message(id=17506,
         value="MQTT client [%s] disconnected")
void clientDisconnected​(String clientIdentifier)

      • pingReceived

        @LogMessage(level=TRACE)
@Message(id=17507,
         value="Ping received from client [%s]")
void pingReceived​(String clientIdentifier)

      • receivedMessageFromClient

        @LogMessage(level=DEBUG)
@Message(id=17508,
         value="Just received message [%s] with QoS [%s] from client [%s]")
void receivedMessageFromClient​(io.vertx.mutiny.core.buffer.Buffer buffer,
                               io.netty.handler.codec.mqtt.MqttQoS qos,
                               String client)

      • sendToClient

        @LogMessage(level=TRACE)
@Message(id=17509,
         value="Send %s to client [%s] for message [%s]")
void sendToClient​(String f,
                  String client,
                  int messageId)

      • receivedSubscription

        @LogMessage(level=TRACE)
@Message(id=17510,
         value="Received subscription message %s from client [%s], closing connection")
void receivedSubscription​(io.vertx.mutiny.mqtt.messages.MqttSubscribeMessage message,
                          String client)

      • serverListeningOn

        @LogMessage(level=INFO)
@Message(id=17511,
         value="MQTT server listening on %s:%s")
void serverListeningOn​(String host,
                       int port)

      • failedToStart

        @LogMessage(level=ERROR)
@Message(id=17512,
         value="Failed to start MQTT server")
void failedToStart​(@Cause
                   Throwable t)

      • newSubscriberAdded

        @LogMessage(level=DEBUG)
@Message(id=17513,
         value="New subscriber added %s")
void newSubscriberAdded​(org.reactivestreams.Subscription subscription)

      • exceptionWhileClosing

        @LogMessage(level=WARN)
@Message(id=17514,
         value="An exception has been caught while closing the MQTT server")
void exceptionWhileClosing​(@Cause
                           Throwable t)

      • closed

        @LogMessage(level=DEBUG)
@Message(id=17515,
         value="MQTT server closed")
void closed()