Class ActiveMQAMQPProtocolLogger_impl

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.logger.ActiveMQAMQPProtocolLogger_impl

All Implemented Interfaces:

ActiveMQAMQPProtocolLogger

public class ActiveMQAMQPProtocolLogger_impl
extends Object
implements ActiveMQAMQPProtocolLogger

Field Summary

Fields inherited from interface ActiveMQAMQPProtocolLogger

LOGGER

Constructor Summary

Constructors

Constructor	Description
ActiveMQAMQPProtocolLogger_impl(org.slf4j.Logger logger)

Method Summary

Modifier and Type	Method	Description
void	ackRetryFailed(Object ackRetryInformation, Object address, long queueID)
void	cantRemovingScheduledTask()
void	duplicateNodeStoreID(String queue, String serverId, long recordID, Exception trace)
void	incompatibleAddressFullMessagePolicy(String oldAddress, String oldPolicy, String newAddress, String newPolicy)
void	interruptedAckManager(Exception e)
void	invalidAMQPConnectionState(Object state, Object remoteIP)
void	messageConversionFailed(Throwable t)
void	retryConnection(String name, String hostAndPort, int currentRetry, int maxRetry)
void	retryConnectionFailed(String name, String hostAndPort, int currentRetry)
void	successReconnect(String name, String hostAndPort, int currentRetry)
void	timedOutAckManager(long timeout)
void	unableToSendMessageToDLA(org.apache.activemq.artemis.core.server.MessageReference ref, Throwable t)
void	unackWithConsumer(int numberOfConsumers, Object queueName, String nodeID, long messageID)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ActiveMQAMQPProtocolLogger_impl

public ActiveMQAMQPProtocolLogger_impl(org.slf4j.Logger logger)

Method Details

cantRemovingScheduledTask

public void cantRemovingScheduledTask()

Specified by:

cantRemovingScheduledTask in interface ActiveMQAMQPProtocolLogger

retryConnectionFailed

public void retryConnectionFailed(String name,
 String hostAndPort,
 int currentRetry)

Specified by:

retryConnectionFailed in interface ActiveMQAMQPProtocolLogger

retryConnection

public void retryConnection(String name,
 String hostAndPort,
 int currentRetry,
 int maxRetry)

Specified by:

retryConnection in interface ActiveMQAMQPProtocolLogger

successReconnect

public void successReconnect(String name,
 String hostAndPort,
 int currentRetry)

Specified by:

successReconnect in interface ActiveMQAMQPProtocolLogger

incompatibleAddressFullMessagePolicy

public void incompatibleAddressFullMessagePolicy(String oldAddress,
 String oldPolicy,
 String newAddress,
 String newPolicy)

Specified by:

incompatibleAddressFullMessagePolicy in interface ActiveMQAMQPProtocolLogger

messageConversionFailed

public void messageConversionFailed(Throwable t)

Specified by:

messageConversionFailed in interface ActiveMQAMQPProtocolLogger

unableToSendMessageToDLA

public void unableToSendMessageToDLA(org.apache.activemq.artemis.core.server.MessageReference ref,
 Throwable t)

Specified by:

unableToSendMessageToDLA in interface ActiveMQAMQPProtocolLogger

invalidAMQPConnectionState

public void invalidAMQPConnectionState(Object state,
 Object remoteIP)

Specified by:

invalidAMQPConnectionState in interface ActiveMQAMQPProtocolLogger

timedOutAckManager

public void timedOutAckManager(long timeout)

Specified by:

timedOutAckManager in interface ActiveMQAMQPProtocolLogger

interruptedAckManager

public void interruptedAckManager(Exception e)

Specified by:

interruptedAckManager in interface ActiveMQAMQPProtocolLogger

duplicateNodeStoreID

public void duplicateNodeStoreID(String queue,
 String serverId,
 long recordID,
 Exception trace)

Specified by:

duplicateNodeStoreID in interface ActiveMQAMQPProtocolLogger

unackWithConsumer

public void unackWithConsumer(int numberOfConsumers,
 Object queueName,
 String nodeID,
 long messageID)

Specified by:

unackWithConsumer in interface ActiveMQAMQPProtocolLogger

ackRetryFailed

public void ackRetryFailed(Object ackRetryInformation,
 Object address,
 long queueID)

Specified by:

ackRetryFailed in interface ActiveMQAMQPProtocolLogger