@MessageLogger(projectCode="SRMSG",
length=5)
public interface MqttServerLogging
extends org.jboss.logging.BasicLogger
Modifier and Type | Field and Description |
---|---|
static MqttServerLogging |
log |
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) |
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
static final MqttServerLogging log
@LogMessage(level=ERROR) @Message(id=17500, value="Exception thrown") void exceptionThrown(@Cause Throwable t)
@LogMessage(level=DEBUG) @Message(id=17501, value="MQTT client [%s] request to connect, clean session = %s") void requestToConnect(String clientIdentifier, boolean isClean)
@LogMessage(level=TRACE) @Message(id=17502, value="[username = %s, password = %s]") void requestToConnectUserName(String user, String pass)
@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)
@LogMessage(level=TRACE) @Message(id=17504, value="[keep alive timeout = %s]") void requestToConnectKeepAlive(int s)
@LogMessage(level=ERROR) @Message(id=17505, value="Error with client %s") void errorWithClient(String clientIdentifier, @Cause Throwable t)
@LogMessage(level=DEBUG) @Message(id=17506, value="MQTT client [%s] disconnected") void clientDisconnected(String clientIdentifier)
@LogMessage(level=TRACE) @Message(id=17507, value="Ping received from client [%s]") void pingReceived(String clientIdentifier)
@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)
@LogMessage(level=TRACE) @Message(id=17509, value="Send %s to client [%s] for message [%s]") void sendToClient(String f, String client, int messageId)
@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)
@LogMessage(level=INFO) @Message(id=17511, value="MQTT server listening on %s:%s") void serverListeningOn(String host, int port)
@LogMessage(level=ERROR) @Message(id=17512, value="Failed to start MQTT server") void failedToStart(@Cause Throwable t)
@LogMessage(level=DEBUG) @Message(id=17513, value="New subscriber added %s") void newSubscriberAdded(org.reactivestreams.Subscription subscription)
@LogMessage(level=WARN) @Message(id=17514, value="An exception has been caught while closing the MQTT server") void exceptionWhileClosing(@Cause Throwable t)
@LogMessage(level=DEBUG) @Message(id=17515, value="MQTT server closed") void closed()
Copyright © 2018–2021 SmallRye. All rights reserved.