Package org.apache.activemq.artemis.ra.inflow

Class ActiveMQMessageHandler

java.lang.Object

org.apache.activemq.artemis.ra.inflow.ActiveMQMessageHandler

All Implemented Interfaces:

FailoverEventListener, MessageHandler

public class ActiveMQMessageHandler
extends Object
implements MessageHandler, FailoverEventListener

Constructor Summary

Constructors

Constructor	Description
ActiveMQMessageHandler(ConnectionFactoryOptions options, ActiveMQActivation activation, TransactionSynchronizationRegistry tsr, ClientSessionInternal session, ClientSessionFactory cf, int sessionNr)

Method Summary

Modifier and Type	Method	Description
void	failoverEvent(FailoverEventType eventType)	Notifies that a connection state has changed according the specified event type.
Thread	getCurrentThread()
Thread	interruptConsumer(FutureLatch future)
void	onMessage(ClientMessage message)	Notifies the MessageHandler that a message has been received.
void	onMessageExpired(ClientMessage message)	Notifies the MessageHandler that an expired message has been received.
void	setup()
void	start()
void	teardown()	Stop the handler

Methods inherited from class java.lang.Object

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

Constructor Details

ActiveMQMessageHandler

public ActiveMQMessageHandler(ConnectionFactoryOptions options,
 ActiveMQActivation activation,
 TransactionSynchronizationRegistry tsr,
 ClientSessionInternal session,
 ClientSessionFactory cf,
 int sessionNr)

Method Details

setup

public void setup()
           throws Exception

Throws:

Exception

getCurrentThread

public Thread getCurrentThread()

interruptConsumer

public Thread interruptConsumer(FutureLatch future)

teardown

public void teardown()

Stop the handler

onMessage

public void onMessage(ClientMessage message)

Description copied from interface: MessageHandler

Notifies the MessageHandler that a message has been received.

Specified by:

onMessage in interface MessageHandler

Parameters:

message - a message

onMessageExpired

public void onMessageExpired(ClientMessage message)

Description copied from interface: MessageHandler

Notifies the MessageHandler that an expired message has been received.

Specified by:

onMessageExpired in interface MessageHandler

Parameters:

message - a message

start

public void start()
           throws ActiveMQException

Throws:

ActiveMQException

failoverEvent

public void failoverEvent(FailoverEventType eventType)

Description copied from interface: FailoverEventListener

Notifies that a connection state has changed according the specified event type.

This method is called when failover is detected, if it fails and when it's completed

Specified by:

failoverEvent in interface FailoverEventListener

Parameters:

eventType - The type of event