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)