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

Class FederatedQueueConsumerImpl

java.lang.Object

org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumerImpl

All Implemented Interfaces:

MessageHandler, SessionFailureListener, FailureListener, FederatedQueueConsumer

public class FederatedQueueConsumerImpl
extends Object
implements FederatedQueueConsumer, SessionFailureListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	FederatedQueueConsumerImpl.ClientSessionCallback

Field Summary

Fields inherited from interface org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer

FEDERATION_NAME, FEDERATION_UPSTREAM_NAME

Constructor Summary

Constructors

Constructor	Description
FederatedQueueConsumerImpl(Federation federation, ActiveMQServer server, Transformer transformer, FederatedConsumerKey key, FederationUpstream upstream, FederatedQueueConsumerImpl.ClientSessionCallback clientSessionCallback)

Method Summary

Modifier and Type	Method	Description
void	beforeReconnect(ActiveMQException exception)	Notifies that a connection has failed due to the specified exception.
void	close()
void	connectionFailed(ActiveMQException exception, boolean failedOver)	Notifies that a connection has failed due to the specified exception.
void	connectionFailed(ActiveMQException exception, boolean failedOver, String scaleDownTargetNodeID)	Notifies that a connection has failed due to the specified exception.
int	decrementCount()
ClientSession	getClientSession()
Federation	getFederation()
FederationUpstream	getFederationUpstream()
FederatedConsumerKey	getKey()
int	incrementCount()
void	onMessage(ClientMessage clientMessage)	Notifies the MessageHandler that a message has been received.
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

FederatedQueueConsumerImpl

public FederatedQueueConsumerImpl(Federation federation,
                                  ActiveMQServer server,
                                  Transformer transformer,
                                  FederatedConsumerKey key,
                                  FederationUpstream upstream,
                                  FederatedQueueConsumerImpl.ClientSessionCallback clientSessionCallback)

Method Detail

getFederationUpstream

public FederationUpstream getFederationUpstream()

Specified by:

getFederationUpstream in interface FederatedQueueConsumer

getFederation

public Federation getFederation()

Specified by:

getFederation in interface FederatedQueueConsumer

getKey

public FederatedConsumerKey getKey()

Specified by:

getKey in interface FederatedQueueConsumer

getClientSession

public ClientSession getClientSession()

Specified by:

getClientSession in interface FederatedQueueConsumer

incrementCount

public int incrementCount()

Specified by:

incrementCount in interface FederatedQueueConsumer

decrementCount

public int decrementCount()

Specified by:

decrementCount in interface FederatedQueueConsumer

start

public void start()

Specified by:

start in interface FederatedQueueConsumer

close

public void close()

Specified by:

close in interface FederatedQueueConsumer

onMessage

public void onMessage(ClientMessage clientMessage)

Description copied from interface: MessageHandler

Notifies the MessageHandler that a message has been received.

Specified by:

onMessage in interface MessageHandler

Parameters:

clientMessage - a message

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 exception,
                             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:

exception - exception which has caused the connection to fail

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

beforeReconnect

public void beforeReconnect(ActiveMQException exception)

Description copied from interface: SessionFailureListener

Notifies that a connection has failed due to the specified exception.
This method is called before the session attempts to reconnect/failover.

Specified by:

beforeReconnect in interface SessionFailureListener

Parameters:

exception - exception which has caused the connection to fail