Package org.apache.activemq.artemis.core.client

Class ActiveMQClientLogger_impl

java.lang.Object

org.apache.activemq.artemis.core.client.ActiveMQClientLogger_impl

All Implemented Interfaces:

ActiveMQClientLogger

public class ActiveMQClientLogger_impl
extends Object
implements ActiveMQClientLogger

Field Summary

Fields inherited from interface org.apache.activemq.artemis.core.client.ActiveMQClientLogger

LOGGER

Constructor Summary

Constructors

Constructor	Description
ActiveMQClientLogger_impl(Logger logger)

Method Summary

Modifier and Type	Method	Description
void	broadcastGroupBindError(String hostAndPort)
void	broadcastGroupBindErrorRetry(String hostAndPort, Throwable t)
void	broadcastTimeout(int retry, int maxretry)
void	cannotFindPacketToClear(Integer lastReceivedCommandID, Integer firstStoredCommandID)
void	caughtunexpectedThrowable(Throwable t)
void	clientSessionNotClosed(int identity, Exception e)
void	commitAfterFailover()
void	compressedLargeMessageError(int length, int nReadBytes)
void	confirmationWindowDisabledWarning()	Warns about usage of SendAcknowledgementHandler or JMS's CompletionWindow with confirmations disabled (confirmationWindowSize=-1).
void	connectionClosureDetected(String remoteAddress, String message, ActiveMQExceptionType type)
void	connectionFailureDetected(String protocol, String remoteAddress, String message, ActiveMQExceptionType type)
void	createConnectorException(Exception e)
void	disconnectOnErrorDecoding(Throwable cause)
void	errorAddingPacket(Exception e)
void	errorCallingCancel(Exception e)
void	errorCallingEnd(Throwable t)
void	errorCallingFailureListener(Throwable e)
void	errorCallingInterceptor(Interceptor interceptor, Throwable e)
void	errorCallingLifeCycleListener(Throwable e)
void	errorCallingStart(String message, Integer code)
void	errorClearingMessages(Throwable e)
void	errorClosingCache(Exception e)
void	errorConnectingToNodes(Exception e)
void	errorCreatingNettyConnection(Throwable e)
void	errorDecodingPacket(Throwable e)
void	errorDuringPrepare(Throwable e)
void	errorFinalisingCache(Exception e)
void	errorOnXMLTransform(Node n, Throwable t)
void	errorOnXMLTransformInvalidConf(Throwable t)
void	errorReadingCache(Exception e)
void	errorReadingIndex(Exception e)
void	errorReceivingPacketInDiscovery(Throwable e)
void	errorReSettingIndex(Exception e)
void	errorSendingNotifOnDiscoveryStop(Throwable e)
void	errorSendingTopology(Throwable e)
void	errorSendingTopologyNodedown(Throwable e)
void	errorSettingIndex(Exception e)
void	errorStartingLocator(Exception e)
void	errorStoppingDiscoveryBroadcastEndpoint(Object endpoint, Throwable t)
void	factoryLeftOpen(int i, Exception e)
void	failedCleaningUp(String target)
void	failedForceClose(Throwable e)
void	failedPerformPostActionsOnMessage(Exception e)
void	failedToBind(String p1, String p2, Throwable cause)
void	failedToCallListenerInDiscovery(Throwable e)
void	failedToCleanupSession(Exception e)
void	failedToConnectToServer()
void	failedToConnectToServer(Integer reconnectAttempts)
void	failedToExecuteListener(Throwable t)
void	failedToHandleFailover(Throwable t)
void	failedToHandlePacket(Exception e)
void	failedToReceiveDatagramInDiscovery(Throwable e)
void	failedToSetChannelReadyForWriting(Throwable e)
void	failedToStopDiscovery(Throwable e)
void	failoverDuringCommit()
void	failoverDuringPrepareRollingBack()
void	ignoredParameterForDownstreamFederation(String name)
void	invalidCFType(String type, String uri)
void	invalidCipherSuite(String validSuites)
void	invalidConcurrentSessionUsage(Throwable t)
void	invalidProtocol(String validProtocols)
void	ioDiscoveryError(String hostAddress, String s)
void	jvmAllocatedMoreMemory(Long totalMemory1, Long totalMemory2)
void	multipleServersBroadcastingSameNode(String nodeId)
void	negativeRefCount(String message, String count, String debugString)
void	noVersionOnClasspath(String classpath)
void	oldStoreProvider(String value)
void	onMessageError(Throwable e)
void	outOfCreditOnFlowControl(String address)
void	packetOutOfOrder(Object obj, Throwable t)
void	propertyNotBoolean(String propName, String name)
void	propertyNotInteger(String propName, String name)
void	propertyNotLong(String propName, String name)
void	receivedExceptionAsynchronously(Exception e)
void	resettingSessionAfterFailure()
void	retryCreateSessionSeverStarting(String name)
void	sessionNotXA()
void	timedOutStoppingDiscovery()
void	timedOutWaitingForScheduledPoolTermination()
void	timedOutWaitingForTermination()
void	timeoutClosingNettyChannel()
void	timeoutClosingSSL()
void	timeoutFlushingPacket()
void	timeoutStreamingLargeMessage()
void	timeOutWaitingForProcessing(long duration)
void	unableToCheckEpollAvailability(Throwable e)
void	unableToCheckEpollAvailabilitynoClass()
void	unableToCheckKQueueAvailability(Throwable e)
void	unableToCheckKQueueAvailabilityNoClass()
void	unableToCloseConsumer(Exception e)
void	unableToCloseSession(Exception e)
void	unableToGetMessage(Exception e)
void	unableToGetProperty(Throwable e)
void	unableToHandleConnectionFailure(Throwable e)
void	unableToInitVersionLoader(Throwable e)
void	unableToInitVersionLoaderError(Throwable e)
void	unableToParseValue(Throwable e)
void	unableToProcessGlobalFlowControlThreadPoolIn10Sec()
void	unableToProcessGlobalThreadPoolIn10Sec()
void	unableToProcessScheduledlIn10Sec()
void	unableToReceiveBroadcast(String target, Exception e)
void	unableToReceiveClusterTopology(Throwable e)
void	unableToResolveHost(UnknownHostException e)
void	unexpectedNullDataReceived()

Methods inherited from class java.lang.Object

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

Constructor Details

ActiveMQClientLogger_impl

public ActiveMQClientLogger_impl(Logger logger)

Method Details

errorClearingMessages

public void errorClearingMessages(Throwable e)

Specified by:

errorClearingMessages in interface ActiveMQClientLogger

timeOutWaitingForProcessing

public void timeOutWaitingForProcessing(long duration)

Specified by:

timeOutWaitingForProcessing in interface ActiveMQClientLogger

unableToCloseSession

public void unableToCloseSession(Exception e)

Specified by:

unableToCloseSession in interface ActiveMQClientLogger

failedToConnectToServer

public void failedToConnectToServer()

Specified by:

failedToConnectToServer in interface ActiveMQClientLogger

failedToConnectToServer

public void failedToConnectToServer(Integer reconnectAttempts)

Specified by:

failedToConnectToServer in interface ActiveMQClientLogger

createConnectorException

public void createConnectorException(Exception e)

Specified by:

createConnectorException in interface ActiveMQClientLogger

factoryLeftOpen

public void factoryLeftOpen(int i,
 Exception e)

Specified by:

factoryLeftOpen in interface ActiveMQClientLogger

resettingSessionAfterFailure

public void resettingSessionAfterFailure()

Specified by:

resettingSessionAfterFailure in interface ActiveMQClientLogger

retryCreateSessionSeverStarting

public void retryCreateSessionSeverStarting(String name)

Specified by:

retryCreateSessionSeverStarting in interface ActiveMQClientLogger

commitAfterFailover

public void commitAfterFailover()

Specified by:

commitAfterFailover in interface ActiveMQClientLogger

failoverDuringCommit

public void failoverDuringCommit()

Specified by:

failoverDuringCommit in interface ActiveMQClientLogger

failoverDuringPrepareRollingBack

public void failoverDuringPrepareRollingBack()

Specified by:

failoverDuringPrepareRollingBack in interface ActiveMQClientLogger

errorDuringPrepare

public void errorDuringPrepare(Throwable e)

Specified by:

errorDuringPrepare in interface ActiveMQClientLogger

clientSessionNotClosed

public void clientSessionNotClosed(int identity,
 Exception e)

Specified by:

clientSessionNotClosed in interface ActiveMQClientLogger

errorAddingPacket

public void errorAddingPacket(Exception e)

Specified by:

errorAddingPacket in interface ActiveMQClientLogger

errorCallingCancel

public void errorCallingCancel(Exception e)

Specified by:

errorCallingCancel in interface ActiveMQClientLogger

errorReadingIndex

public void errorReadingIndex(Exception e)

Specified by:

errorReadingIndex in interface ActiveMQClientLogger

errorSettingIndex

public void errorSettingIndex(Exception e)

Specified by:

errorSettingIndex in interface ActiveMQClientLogger

errorReSettingIndex

public void errorReSettingIndex(Exception e)

Specified by:

errorReSettingIndex in interface ActiveMQClientLogger

errorReadingCache

public void errorReadingCache(Exception e)

Specified by:

errorReadingCache in interface ActiveMQClientLogger

errorClosingCache

public void errorClosingCache(Exception e)

Specified by:

errorClosingCache in interface ActiveMQClientLogger

errorFinalisingCache

public void errorFinalisingCache(Exception e)

Specified by:

errorFinalisingCache in interface ActiveMQClientLogger

errorConnectingToNodes

public void errorConnectingToNodes(Exception e)

Specified by:

errorConnectingToNodes in interface ActiveMQClientLogger

timedOutWaitingForTermination

public void timedOutWaitingForTermination()

Specified by:

timedOutWaitingForTermination in interface ActiveMQClientLogger

timedOutWaitingForScheduledPoolTermination

public void timedOutWaitingForScheduledPoolTermination()

Specified by:

timedOutWaitingForScheduledPoolTermination in interface ActiveMQClientLogger

errorStartingLocator

public void errorStartingLocator(Exception e)

Specified by:

errorStartingLocator in interface ActiveMQClientLogger

errorSendingTopology

public void errorSendingTopology(Throwable e)

Specified by:

errorSendingTopology in interface ActiveMQClientLogger

errorSendingTopologyNodedown

public void errorSendingTopologyNodedown(Throwable e)

Specified by:

errorSendingTopologyNodedown in interface ActiveMQClientLogger

timedOutStoppingDiscovery

public void timedOutStoppingDiscovery()

Specified by:

timedOutStoppingDiscovery in interface ActiveMQClientLogger

errorSendingNotifOnDiscoveryStop

public void errorSendingNotifOnDiscoveryStop(Throwable e)

Specified by:

errorSendingNotifOnDiscoveryStop in interface ActiveMQClientLogger

multipleServersBroadcastingSameNode

public void multipleServersBroadcastingSameNode(String nodeId)

Specified by:

multipleServersBroadcastingSameNode in interface ActiveMQClientLogger

errorReceivingPacketInDiscovery

public void errorReceivingPacketInDiscovery(Throwable e)

Specified by:

errorReceivingPacketInDiscovery in interface ActiveMQClientLogger

cannotFindPacketToClear

public void cannotFindPacketToClear(Integer lastReceivedCommandID,
 Integer firstStoredCommandID)

Specified by:

cannotFindPacketToClear in interface ActiveMQClientLogger

connectionFailureDetected

public void connectionFailureDetected(String protocol,
 String remoteAddress,
 String message,
 ActiveMQExceptionType type)

Specified by:

connectionFailureDetected in interface ActiveMQClientLogger

errorCallingInterceptor

public void errorCallingInterceptor(Interceptor interceptor,
 Throwable e)

Specified by:

errorCallingInterceptor in interface ActiveMQClientLogger

timeoutClosingSSL

public void timeoutClosingSSL()

Specified by:

timeoutClosingSSL in interface ActiveMQClientLogger

timeoutClosingNettyChannel

public void timeoutClosingNettyChannel()

Specified by:

timeoutClosingNettyChannel in interface ActiveMQClientLogger

timeoutFlushingPacket

public void timeoutFlushingPacket()

Specified by:

timeoutFlushingPacket in interface ActiveMQClientLogger

propertyNotInteger

public void propertyNotInteger(String propName,
 String name)

Specified by:

propertyNotInteger in interface ActiveMQClientLogger

propertyNotLong

public void propertyNotLong(String propName,
 String name)

Specified by:

propertyNotLong in interface ActiveMQClientLogger

propertyNotBoolean

public void propertyNotBoolean(String propName,
 String name)

Specified by:

propertyNotBoolean in interface ActiveMQClientLogger

noVersionOnClasspath

public void noVersionOnClasspath(String classpath)

Specified by:

noVersionOnClasspath in interface ActiveMQClientLogger

jvmAllocatedMoreMemory

public void jvmAllocatedMoreMemory(Long totalMemory1,
 Long totalMemory2)

Specified by:

jvmAllocatedMoreMemory in interface ActiveMQClientLogger

broadcastGroupBindErrorRetry

public void broadcastGroupBindErrorRetry(String hostAndPort,
 Throwable t)

Specified by:

broadcastGroupBindErrorRetry in interface ActiveMQClientLogger

ioDiscoveryError

public void ioDiscoveryError(String hostAddress,
 String s)

Specified by:

ioDiscoveryError in interface ActiveMQClientLogger

compressedLargeMessageError

public void compressedLargeMessageError(int length,
 int nReadBytes)

Specified by:

compressedLargeMessageError in interface ActiveMQClientLogger

invalidConcurrentSessionUsage

public void invalidConcurrentSessionUsage(Throwable t)

Specified by:

invalidConcurrentSessionUsage in interface ActiveMQClientLogger

packetOutOfOrder

public void packetOutOfOrder(Object obj,
 Throwable t)

Specified by:

packetOutOfOrder in interface ActiveMQClientLogger

confirmationWindowDisabledWarning

public void confirmationWindowDisabledWarning()

Description copied from interface: ActiveMQClientLogger

Warns about usage of SendAcknowledgementHandler or JMS's CompletionWindow with confirmations disabled (confirmationWindowSize=-1).

Specified by:

confirmationWindowDisabledWarning in interface ActiveMQClientLogger

outOfCreditOnFlowControl

public void outOfCreditOnFlowControl(String address)

Specified by:

outOfCreditOnFlowControl in interface ActiveMQClientLogger

unableToCloseConsumer

public void unableToCloseConsumer(Exception e)

Specified by:

unableToCloseConsumer in interface ActiveMQClientLogger

broadcastGroupBindError

public void broadcastGroupBindError(String hostAndPort)

Specified by:

broadcastGroupBindError in interface ActiveMQClientLogger

timeoutStreamingLargeMessage

public void timeoutStreamingLargeMessage()

Specified by:

timeoutStreamingLargeMessage in interface ActiveMQClientLogger

unableToGetMessage

public void unableToGetMessage(Exception e)

Specified by:

unableToGetMessage in interface ActiveMQClientLogger

failedCleaningUp

public void failedCleaningUp(String target)

Specified by:

failedCleaningUp in interface ActiveMQClientLogger

unexpectedNullDataReceived

public void unexpectedNullDataReceived()

Specified by:

unexpectedNullDataReceived in interface ActiveMQClientLogger

failedForceClose

public void failedForceClose(Throwable e)

Specified by:

failedForceClose in interface ActiveMQClientLogger

failedPerformPostActionsOnMessage

public void failedPerformPostActionsOnMessage(Exception e)

Specified by:

failedPerformPostActionsOnMessage in interface ActiveMQClientLogger

unableToHandleConnectionFailure

public void unableToHandleConnectionFailure(Throwable e)

Specified by:

unableToHandleConnectionFailure in interface ActiveMQClientLogger

unableToReceiveClusterTopology

public void unableToReceiveClusterTopology(Throwable e)

Specified by:

unableToReceiveClusterTopology in interface ActiveMQClientLogger

unableToReceiveBroadcast

public void unableToReceiveBroadcast(String target,
 Exception e)

Specified by:

unableToReceiveBroadcast in interface ActiveMQClientLogger

unableToParseValue

public void unableToParseValue(Throwable e)

Specified by:

unableToParseValue in interface ActiveMQClientLogger

unableToGetProperty

public void unableToGetProperty(Throwable e)

Specified by:

unableToGetProperty in interface ActiveMQClientLogger

unableToProcessGlobalThreadPoolIn10Sec

public void unableToProcessGlobalThreadPoolIn10Sec()

Specified by:

unableToProcessGlobalThreadPoolIn10Sec in interface ActiveMQClientLogger

unableToProcessScheduledlIn10Sec

public void unableToProcessScheduledlIn10Sec()

Specified by:

unableToProcessScheduledlIn10Sec in interface ActiveMQClientLogger

unableToInitVersionLoader

public void unableToInitVersionLoader(Throwable e)

Specified by:

unableToInitVersionLoader in interface ActiveMQClientLogger

unableToCheckEpollAvailability

public void unableToCheckEpollAvailability(Throwable e)

Specified by:

unableToCheckEpollAvailability in interface ActiveMQClientLogger

failedToSetChannelReadyForWriting

public void failedToSetChannelReadyForWriting(Throwable e)

Specified by:

failedToSetChannelReadyForWriting in interface ActiveMQClientLogger

unableToCheckKQueueAvailability

public void unableToCheckKQueueAvailability(Throwable e)

Specified by:

unableToCheckKQueueAvailability in interface ActiveMQClientLogger

unableToCheckKQueueAvailabilityNoClass

public void unableToCheckKQueueAvailabilityNoClass()

Specified by:

unableToCheckKQueueAvailabilityNoClass in interface ActiveMQClientLogger

unableToCheckEpollAvailabilitynoClass

public void unableToCheckEpollAvailabilitynoClass()

Specified by:

unableToCheckEpollAvailabilitynoClass in interface ActiveMQClientLogger

broadcastTimeout

public void broadcastTimeout(int retry,
 int maxretry)

Specified by:

broadcastTimeout in interface ActiveMQClientLogger

ignoredParameterForDownstreamFederation

public void ignoredParameterForDownstreamFederation(String name)

Specified by:

ignoredParameterForDownstreamFederation in interface ActiveMQClientLogger

oldStoreProvider

public void oldStoreProvider(String value)

Specified by:

oldStoreProvider in interface ActiveMQClientLogger

onMessageError

public void onMessageError(Throwable e)

Specified by:

onMessageError in interface ActiveMQClientLogger

failedToCleanupSession

public void failedToCleanupSession(Exception e)

Specified by:

failedToCleanupSession in interface ActiveMQClientLogger

failedToExecuteListener

public void failedToExecuteListener(Throwable t)

Specified by:

failedToExecuteListener in interface ActiveMQClientLogger

failedToHandleFailover

public void failedToHandleFailover(Throwable t)

Specified by:

failedToHandleFailover in interface ActiveMQClientLogger

errorCallingEnd

public void errorCallingEnd(Throwable t)

Specified by:

errorCallingEnd in interface ActiveMQClientLogger

errorCallingStart

public void errorCallingStart(String message,
 Integer code)

Specified by:

errorCallingStart in interface ActiveMQClientLogger

sessionNotXA

public void sessionNotXA()

Specified by:

sessionNotXA in interface ActiveMQClientLogger

receivedExceptionAsynchronously

public void receivedExceptionAsynchronously(Exception e)

Specified by:

receivedExceptionAsynchronously in interface ActiveMQClientLogger

failedToHandlePacket

public void failedToHandlePacket(Exception e)

Specified by:

failedToHandlePacket in interface ActiveMQClientLogger

failedToStopDiscovery

public void failedToStopDiscovery(Throwable e)

Specified by:

failedToStopDiscovery in interface ActiveMQClientLogger

failedToReceiveDatagramInDiscovery

public void failedToReceiveDatagramInDiscovery(Throwable e)

Specified by:

failedToReceiveDatagramInDiscovery in interface ActiveMQClientLogger

failedToCallListenerInDiscovery

public void failedToCallListenerInDiscovery(Throwable e)

Specified by:

failedToCallListenerInDiscovery in interface ActiveMQClientLogger

errorDecodingPacket

public void errorDecodingPacket(Throwable e)

Specified by:

errorDecodingPacket in interface ActiveMQClientLogger

errorCallingFailureListener

public void errorCallingFailureListener(Throwable e)

Specified by:

errorCallingFailureListener in interface ActiveMQClientLogger

errorCallingLifeCycleListener

public void errorCallingLifeCycleListener(Throwable e)

Specified by:

errorCallingLifeCycleListener in interface ActiveMQClientLogger

errorCreatingNettyConnection

public void errorCreatingNettyConnection(Throwable e)

Specified by:

errorCreatingNettyConnection in interface ActiveMQClientLogger

caughtunexpectedThrowable

public void caughtunexpectedThrowable(Throwable t)

Specified by:

caughtunexpectedThrowable in interface ActiveMQClientLogger

errorOnXMLTransform

public void errorOnXMLTransform(Node n,
 Throwable t)

Specified by:

errorOnXMLTransform in interface ActiveMQClientLogger

errorOnXMLTransformInvalidConf

public void errorOnXMLTransformInvalidConf(Throwable t)

Specified by:

errorOnXMLTransformInvalidConf in interface ActiveMQClientLogger

errorStoppingDiscoveryBroadcastEndpoint

public void errorStoppingDiscoveryBroadcastEndpoint(Object endpoint,
 Throwable t)

Specified by:

errorStoppingDiscoveryBroadcastEndpoint in interface ActiveMQClientLogger

invalidCipherSuite

public void invalidCipherSuite(String validSuites)

Specified by:

invalidCipherSuite in interface ActiveMQClientLogger

invalidProtocol

public void invalidProtocol(String validProtocols)

Specified by:

invalidProtocol in interface ActiveMQClientLogger

invalidCFType

public void invalidCFType(String type,
 String uri)

Specified by:

invalidCFType in interface ActiveMQClientLogger

failedToBind

public void failedToBind(String p1,
 String p2,
 Throwable cause)

Specified by:

failedToBind in interface ActiveMQClientLogger

disconnectOnErrorDecoding

public void disconnectOnErrorDecoding(Throwable cause)

Specified by:

disconnectOnErrorDecoding in interface ActiveMQClientLogger

unableToInitVersionLoaderError

public void unableToInitVersionLoaderError(Throwable e)

Specified by:

unableToInitVersionLoaderError in interface ActiveMQClientLogger

unableToResolveHost

public void unableToResolveHost(UnknownHostException e)

Specified by:

unableToResolveHost in interface ActiveMQClientLogger

negativeRefCount

public void negativeRefCount(String message,
 String count,
 String debugString)

Specified by:

negativeRefCount in interface ActiveMQClientLogger

unableToProcessGlobalFlowControlThreadPoolIn10Sec

public void unableToProcessGlobalFlowControlThreadPoolIn10Sec()

Specified by:

unableToProcessGlobalFlowControlThreadPoolIn10Sec in interface ActiveMQClientLogger

connectionClosureDetected

public void connectionClosureDetected(String remoteAddress,
 String message,
 ActiveMQExceptionType type)

Specified by:

connectionClosureDetected in interface ActiveMQClientLogger