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()
ScheduledFuture	getCurrentConnectTask()
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

Methods inherited from interface org.apache.activemq.artemis.api.core.client.MessageHandler

onMessageExpired

Constructor Details

FederatedQueueConsumerImpl

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

Method Details

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

getCurrentConnectTask

public ScheduledFuture getCurrentConnectTask()