Package org.apache.activemq.artemis.core.server.impl

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

Modifier and Type	Method	Description
void	connectionClosed()	called when the connection is closed
void	connectionFailed(ActiveMQException exception, boolean failedOver)	Notifies that a connection has failed due to the specified exception.
void	connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)	Notifies that a connection has failed due to the specified exception.
void	setObserver(TempQueueObserver observer)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

TempQueueCleanerUpper

public TempQueueCleanerUpper(ActiveMQServer server,
 SimpleString bindingName)

Method Details

setObserver

public void setObserver(TempQueueObserver observer)

connectionFailed

public void connectionFailed(ActiveMQException exception,
 boolean failedOver)

Description copied from interface: FailureListener

Notifies that a connection has failed due to the specified exception.

Specified by:

connectionFailed in interface FailureListener

Parameters:

exception - exception which has caused the connection to fail

connectionFailed

public void connectionFailed(ActiveMQException me,
 boolean failedOver,
 String scaleDownTargetNodeID)

Description copied from interface: FailureListener

Notifies that a connection has failed due to the specified exception.

Specified by:

connectionFailed in interface FailureListener

Parameters:

me - exception which has caused the connection to fail

scaleDownTargetNodeID - the ID of the node to which messages are scaling down

connectionClosed

public void connectionClosed()

Description copied from interface: CloseListener

called when the connection is closed

Specified by:

connectionClosed in interface CloseListener

toString

public String toString()

Overrides:

toString in class Object