Interface ActiveMQAMQPProtocolLogger

All Known Implementing Classes:

ActiveMQAMQPProtocolLogger_impl

public interface ActiveMQAMQPProtocolLogger

Logger Codes 110000 - 118999

Field Summary

Fields

Modifier and Type	Field	Description
static final ActiveMQAMQPProtocolLogger	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)

Field Details

LOGGER

static final ActiveMQAMQPProtocolLogger LOGGER

Method Details

cantRemovingScheduledTask

void cantRemovingScheduledTask()

retryConnectionFailed

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

retryConnection

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

successReconnect

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

incompatibleAddressFullMessagePolicy

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

messageConversionFailed

void messageConversionFailed(Throwable t)

unableToSendMessageToDLA

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

invalidAMQPConnectionState

void invalidAMQPConnectionState(Object state,
 Object remoteIP)

timedOutAckManager

void timedOutAckManager(long timeout)

interruptedAckManager

void interruptedAckManager(Exception e)

duplicateNodeStoreID

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

unackWithConsumer

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

ackRetryFailed

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