io.smallrye.reactive.messaging.rabbitmq.i18n

Interface RabbitMQLogging

All Superinterfaces:

org.jboss.logging.BasicLogger

All Known Implementing Classes:

RabbitMQLogging_$logger

@MessageLogger(projectCode="SRMSG",
               length=5)
public interface RabbitMQLogging
extends org.jboss.logging.BasicLogger

Field Summary

Fields

Modifier and Type	Field and Description
static RabbitMQLogging	log

Method Summary

Modifier and Type	Method and Description
void	ackAutoMessage(String channel)
void	ackMessage(String channel)
void	bindingEstablished(String queueName, String exchangeName, String routingKey)
void	connectionEstablished(String channel)
void	dlxEstablished(String deadLetterExchangeName)
void	establishingConnection(String channel)
void	exchangeEstablished(String exchangeName)
void	failureReported(String channel, Throwable reason)
void	fullIgnoredFailure(Throwable t)
void	nackedAcceptMessage(String channel)
void	nackedFailMessage(String channel)
void	nackedIgnoreMessage(String channel)
void	queueEstablished(String queueName)
void	receiverError(Throwable t)
void	receiverListeningAddress(String address)
void	retrieveMessagesNoMoreRetrying(Throwable t)
void	retrieveMessagesRetrying(Throwable t)
void	sendingMessageToExchange(String exchange, String routingKey)
void	serializationFailure(String channel, Throwable reason)
void	unableToConnectToBroker(Throwable t)
void	unableToEstablishBinding(String queueName, String exchangeName, Throwable ex)
void	unableToEstablishDlx(String deadLetterExchangeName, Throwable ex)
void	unableToEstablishExchange(String exchangeName, Throwable ex)
void	unableToEstablishQueue(String exchangeName, Throwable ex)
void	unableToRecoverFromConnectionDisruption(Throwable t)

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 RabbitMQLogging log

Method Detail

receiverListeningAddress

@LogMessage(level=INFO)
 @Message(id=17000,
         value="RabbitMQ Receiver listening address %s")
void receiverListeningAddress(String address)

receiverError

@LogMessage(level=ERROR)
 @Message(id=17001,
         value="RabbitMQ Receiver error")
void receiverError(@Cause
                                                                                                          Throwable t)

retrieveMessagesRetrying

@LogMessage(level=ERROR)
 @Message(id=17002,
         value="Unable to retrieve messages from RabbitMQ, retrying...")
void retrieveMessagesRetrying(@Cause
                                                                                                                                                    Throwable t)

retrieveMessagesNoMoreRetrying

@LogMessage(level=ERROR)
 @Message(id=17003,
         value="Unable to retrieve messages from RabbitMQ, no more retry")
void retrieveMessagesNoMoreRetrying(@Cause
                                                                                                                                                            Throwable t)

establishingConnection

@LogMessage(level=INFO)
 @Message(id=17006,
         value="Establishing connection with RabbitMQ broker for channel `%s`")
void establishingConnection(String channel)

connectionEstablished

@LogMessage(level=INFO)
 @Message(id=17007,
         value="Connection with RabbitMQ broker established for channel `%s`")
void connectionEstablished(String channel)

unableToConnectToBroker

@LogMessage(level=ERROR)
 @Message(id=17008,
         value="Unable to connect to the broker, retry will be attempted")
void unableToConnectToBroker(@Cause
                                                                                                                                                     Throwable t)

unableToRecoverFromConnectionDisruption

@LogMessage(level=ERROR)
 @Message(id=17009,
         value="Unable to recover from RabbitMQ connection disruption")
void unableToRecoverFromConnectionDisruption(@Cause
                                                                                                                                                                  Throwable t)

nackedAcceptMessage

@LogMessage(level=WARN)
 @Message(id=17010,
         value="A message sent to channel `%s` has been nacked, ignoring the failure and marking the RabbitMQ message as accepted")
void nackedAcceptMessage(String channel)

fullIgnoredFailure

@LogMessage(level=DEBUG)
 @Message(id=17011,
         value="The full ignored failure is")
void fullIgnoredFailure(@Cause
                                                                                                                   Throwable t)

nackedFailMessage

@LogMessage(level=ERROR)
 @Message(id=17012,
         value="A message sent to channel `%s` has been nacked, rejecting the RabbitMQ message and fail-stop")
void nackedFailMessage(String channel)

nackedIgnoreMessage

@LogMessage(level=WARN)
 @Message(id=17013,
         value="A message sent to channel `%s` has been nacked, ignoring the failure and marking the RabbitMQ message as rejected")
void nackedIgnoreMessage(String channel)

failureReported

@LogMessage(level=ERROR)
 @Message(id=17018,
         value="Failure reported for channel `%s`, closing client")
void failureReported(String channel,
                                                                                                                                      @Cause
                                                                                                                                      Throwable reason)

serializationFailure

@LogMessage(level=ERROR)
 @Message(id=17021,
         value="Unable to serialize message on channel `%s`, message has been nacked")
void serializationFailure(String channel,
                                                                                                                                                              @Cause
                                                                                                                                                              Throwable reason)

sendingMessageToExchange

@LogMessage(level=DEBUG)
 @Message(id=17022,
         value="Sending a message to exchange `%s` with routing key %s")
void sendingMessageToExchange(String exchange,
                                                                                                                                                    String routingKey)

exchangeEstablished

@LogMessage(level=DEBUG)
 @Message(id=17023,
         value="Established exchange `%s`")
void exchangeEstablished(String exchangeName)

unableToEstablishExchange

@LogMessage(level=ERROR)
 @Message(id=17024,
         value="Unable to establish exchange `%s`")
void unableToEstablishExchange(String exchangeName,
                                                                                                                                @Cause
                                                                                                                                Throwable ex)

queueEstablished

@LogMessage(level=DEBUG)
 @Message(id=17025,
         value="Established queue `%s`")
void queueEstablished(String queueName)

unableToEstablishBinding

@LogMessage(level=ERROR)
 @Message(id=17026,
         value="Unable to bind queue \'%s\' to exchange \'%s\'")
void unableToEstablishBinding(String queueName,
                                                                                                                                            String exchangeName,
                                                                                                                                            @Cause
                                                                                                                                            Throwable ex)

bindingEstablished

@LogMessage(level=DEBUG)
 @Message(id=17027,
         value="Established binding of queue `%s` to exchange \'%s\' using routing key \'%s\'")
void bindingEstablished(String queueName,
                                                                                                                                                                     String exchangeName,
                                                                                                                                                                     String routingKey)

unableToEstablishQueue

@LogMessage(level=ERROR)
 @Message(id=17028,
         value="Unable to establish queue `%s`")
void unableToEstablishQueue(String exchangeName,
                                                                                                                          @Cause
                                                                                                                          Throwable ex)

dlxEstablished

@LogMessage(level=DEBUG)
 @Message(id=17029,
         value="Established dlx `%s`")
void dlxEstablished(String deadLetterExchangeName)

unableToEstablishDlx

@LogMessage(level=ERROR)
 @Message(id=17030,
         value="Unable to establish dlx `%s`")
void unableToEstablishDlx(String deadLetterExchangeName,
                                                                                                                      @Cause
                                                                                                                      Throwable ex)

ackMessage

@LogMessage(level=INFO)
 @Message(id=17033,
         value="A message sent to channel `%s` has been ack\'d")
void ackMessage(String channel)

ackAutoMessage

@LogMessage(level=INFO)
 @Message(id=17034,
         value="A message sent to channel `%s` has not been explicitly ack\'d as auto-ack is enabled")
void ackAutoMessage(String channel)