Package 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

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

      • createClientFromBean

        @LogMessage(level=DEBUG)
@Message(id=17035,
         value="Creating RabbitMQ client from bean named \'%s\'")
void createClientFromBean​(String optionsBeanName)

      • brokerConfigured

        @LogMessage(level=INFO)
@Message(id=17036,
         value="RabbitMQ broker configured to %s:%d for channel %s")
void brokerConfigured​(String host,
                      int port,
                      String channel)

      • unableToCreateClient

        @LogMessage(level=ERROR)
@Message(id=17037,
         value="Unable to create client")
void unableToCreateClient​(@Cause
                          Throwable t)