Class ActiveMQAMQPProtocolLogger_impl
java.lang.Object
org.apache.activemq.artemis.protocol.amqp.logger.ActiveMQAMQPProtocolLogger_impl
- All Implemented Interfaces:
ActiveMQAMQPProtocolLogger
-
Field Summary
Fields inherited from interface ActiveMQAMQPProtocolLogger
LOGGER -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidackRetryFailed(Object ackRetryInformation, Object address, long queueID) voidvoidduplicateNodeStoreID(String queue, String serverId, long recordID, Exception trace) voidincompatibleAddressFullMessagePolicy(String oldAddress, String oldPolicy, String newAddress, String newPolicy) voidvoidinvalidAMQPConnectionState(Object state, Object remoteIP) voidvoidretryConnection(String name, String hostAndPort, int currentRetry, int maxRetry) voidretryConnectionFailed(String name, String hostAndPort, int currentRetry) voidsuccessReconnect(String name, String hostAndPort, int currentRetry) voidtimedOutAckManager(long timeout) voidunableToSendMessageToDLA(org.apache.activemq.artemis.core.server.MessageReference ref, Throwable t) voidunackWithConsumer(int numberOfConsumers, Object queueName, String nodeID, long messageID)
-
Constructor Details
-
ActiveMQAMQPProtocolLogger_impl
public ActiveMQAMQPProtocolLogger_impl(org.slf4j.Logger logger)
-
-
Method Details
-
cantRemovingScheduledTask
public void cantRemovingScheduledTask()- Specified by:
cantRemovingScheduledTaskin interfaceActiveMQAMQPProtocolLogger
-
retryConnectionFailed
- Specified by:
retryConnectionFailedin interfaceActiveMQAMQPProtocolLogger
-
retryConnection
- Specified by:
retryConnectionin interfaceActiveMQAMQPProtocolLogger
-
successReconnect
- Specified by:
successReconnectin interfaceActiveMQAMQPProtocolLogger
-
incompatibleAddressFullMessagePolicy
public void incompatibleAddressFullMessagePolicy(String oldAddress, String oldPolicy, String newAddress, String newPolicy) - Specified by:
incompatibleAddressFullMessagePolicyin interfaceActiveMQAMQPProtocolLogger
-
messageConversionFailed
- Specified by:
messageConversionFailedin interfaceActiveMQAMQPProtocolLogger
-
unableToSendMessageToDLA
public void unableToSendMessageToDLA(org.apache.activemq.artemis.core.server.MessageReference ref, Throwable t) - Specified by:
unableToSendMessageToDLAin interfaceActiveMQAMQPProtocolLogger
-
invalidAMQPConnectionState
- Specified by:
invalidAMQPConnectionStatein interfaceActiveMQAMQPProtocolLogger
-
timedOutAckManager
public void timedOutAckManager(long timeout) - Specified by:
timedOutAckManagerin interfaceActiveMQAMQPProtocolLogger
-
interruptedAckManager
- Specified by:
interruptedAckManagerin interfaceActiveMQAMQPProtocolLogger
-
duplicateNodeStoreID
- Specified by:
duplicateNodeStoreIDin interfaceActiveMQAMQPProtocolLogger
-
unackWithConsumer
public void unackWithConsumer(int numberOfConsumers, Object queueName, String nodeID, long messageID) - Specified by:
unackWithConsumerin interfaceActiveMQAMQPProtocolLogger
-
ackRetryFailed
- Specified by:
ackRetryFailedin interfaceActiveMQAMQPProtocolLogger
-