Class ServerSessionImpl.TempQueueCleanerUpper
- java.lang.Object
-
- org.apache.activemq.artemis.core.server.impl.ServerSessionImpl.TempQueueCleanerUpper
-
- All Implemented Interfaces:
CloseListener,FailureListener
- Enclosing class:
- ServerSessionImpl
public static class ServerSessionImpl.TempQueueCleanerUpper extends Object implements CloseListener, FailureListener
-
-
Constructor Summary
Constructors Constructor Description TempQueueCleanerUpper(ActiveMQServer server, SimpleString bindingName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidconnectionClosed()called when the connection is closedvoidconnectionFailed(ActiveMQException exception, boolean failedOver)Notifies that a connection has failed due to the specified exception.voidconnectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)Notifies that a connection has failed due to the specified exception.voidsetObserver(TempQueueObserver observer)StringtoString()
-
-
-
Constructor Detail
-
TempQueueCleanerUpper
public TempQueueCleanerUpper(ActiveMQServer server, SimpleString bindingName)
-
-
Method Detail
-
setObserver
public void setObserver(TempQueueObserver observer)
-
connectionFailed
public void connectionFailed(ActiveMQException exception, boolean failedOver)
Description copied from interface:FailureListenerNotifies that a connection has failed due to the specified exception.- Specified by:
connectionFailedin interfaceFailureListener- Parameters:
exception- exception which has caused the connection to fail
-
connectionFailed
public void connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)
Description copied from interface:FailureListenerNotifies that a connection has failed due to the specified exception.- Specified by:
connectionFailedin interfaceFailureListener- Parameters:
me- exception which has caused the connection to failscaleDownTargetNodeID- the ID of the node to which messages are scaling down
-
connectionClosed
public void connectionClosed()
Description copied from interface:CloseListenercalled when the connection is closed- Specified by:
connectionClosedin interfaceCloseListener
-
-