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

Field Summary

Fields

Modifier and Type	Field and Description
static MqttServerLogging	log

Method Summary

Modifier and Type	Method and 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

Field Detail

log

static final MqttServerLogging log

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()