Package io.smallrye.reactive.messaging.amqp.i18n

Interface AMQPLogging

  • All Superinterfaces:
    org.jboss.logging.BasicLogger
    All Known Implementing Classes:
    AMQPLogging_$logger
    @MessageLogger(projectCode="SRMSG",
               length=5)
public interface AMQPLogging
extends org.jboss.logging.BasicLogger
    Logging for AMQP Connector Assigned ID range is 16200-16299

    • Method Detail

      • createClientFromBean

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

      • brokerConfigured

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

      • unableToCreateClient

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

      • receiverListeningAddress

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

      • receiverError

        @LogMessage(level=ERROR)
@Message(id=16204,
         value="AMQP Receiver error")
void receiverError​(@Cause
                   Throwable t)

      • retrieveMessagesRetrying

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

      • retrieveMessagesNoMoreRetrying

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

      • messageNotSendClientClosed

        @LogMessage(level=ERROR)
@Message(id=16207,
         value="The AMQP message has not been sent, the client is closed")
void messageNotSendClientClosed()

      • unableToSendMessage

        @LogMessage(level=ERROR)
@Message(id=16208,
         value="Unable to send the AMQP message")
void unableToSendMessage​(@Cause
                         Throwable t)

      • unableToUseAddress

        @LogMessage(level=WARN)
@Message(id=16209,
         value="Unable to use the address configured in the message (%s) - the connector is not using an anonymous sender, using %s instead")
void unableToUseAddress​(String address,
                        String configuredAddress)

      • messageToAddressNotSend

        @LogMessage(level=ERROR)
@Message(id=16210,
         value="The AMQP message to address `%s` has not been sent, the client is closed")
void messageToAddressNotSend​(String address)

      • sendingMessageToAddress

        @LogMessage(level=DEBUG)
@Message(id=16211,
         value="Sending AMQP message to address `%s`")
void sendingMessageToAddress​(String address)

      • establishingConnection

        @LogMessage(level=INFO)
@Message(id=16212,
         value="Establishing connection with AMQP broker")
void establishingConnection()

      • connectionEstablished

        @LogMessage(level=INFO)
@Message(id=16213,
         value="Connection with AMQP broker established")
void connectionEstablished()

      • connectionFailure

        @LogMessage(level=ERROR)
@Message(id=16214,
         value="AMQP Connection failure")
void connectionFailure​(@Cause
                       Throwable t)

      • unableToConnectToBroker

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

      • unableToRecoverFromConnectionDisruption

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

      • nackedAcceptMessage

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

      • fullIgnoredFailure

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

      • nackedFailMessage

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

      • nackedIgnoreMessage

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

      • nackedReleaseMessage

        @LogMessage(level=WARN)
@Message(id=16221,
         value="A message sent to channel `%s` has been nacked, ignoring the failure and marking the AMQP message as released")
void nackedReleaseMessage​(String channel)

      • retrievedCreditsForChannel

        @LogMessage(level=DEBUG)
@Message(id=16222,
         value="Retrieved credits for channel `%s`: %s")
void retrievedCreditsForChannel​(String channel,
                                long credits)

      • noMoreCreditsForChannel

        @LogMessage(level=DEBUG)
@Message(id=16223,
         value="No more credit for channel %s, requesting more credits")
void noMoreCreditsForChannel​(String channel)

      • messageNoSend

        @LogMessage(level=ERROR)
@Message(id=16224,
         value="The AMQP message to address `%s` has not been sent, the client is closed")
void messageNoSend​(String actualAddress)

      • failureReported

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

      • nackedModifiedFailedMessage

        @LogMessage(level=WARN)
@Message(id=16226,
         value="A message sent to channel `%s` has been nacked, ignoring the message and marking the AMQP message as modified with `delivery-failed`")
void nackedModifiedFailedMessage​(String channel)

      • nackedModifiedFailedMessageAndUndeliverableHere

        @LogMessage(level=WARN)
@Message(id=16227,
         value="A message sent to channel `%s` has been nacked, ignoring the message and marking the AMQP message as modified with `delivery-failed` and `undeliverable-here`")
void nackedModifiedFailedMessageAndUndeliverableHere​(String channel)

      • serializationFailure

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

      • unableToCreateMessage

        @LogMessage(level=ERROR)
@Message(id=16229,
         value="Unable to deserialize AMQP message on channel `%s`, message ignored")
void unableToCreateMessage​(String channel,
                           @Cause
                           Exception e)