public class ActiveMQMessageHandler extends Object implements MessageHandler, FailoverEventListener
Constructor and Description |
---|
ActiveMQMessageHandler(ConnectionFactoryOptions options,
ActiveMQActivation activation,
TransactionManager tm,
ClientSessionInternal session,
ClientSessionFactory cf,
int sessionNr) |
Modifier and Type | Method and Description |
---|---|
void |
failoverEvent(FailoverEventType eventType)
Notifies that a connection state has changed according the specified event type.
|
Thread |
interruptConsumer(FutureLatch future) |
void |
onMessage(ClientMessage message)
Notifies the MessageHandler that a message has been received.
|
void |
setup() |
void |
start() |
void |
teardown()
Stop the handler
|
public ActiveMQMessageHandler(ConnectionFactoryOptions options, ActiveMQActivation activation, TransactionManager tm, ClientSessionInternal session, ClientSessionFactory cf, int sessionNr)
public Thread interruptConsumer(FutureLatch future)
public void teardown()
public void onMessage(ClientMessage message)
MessageHandler
onMessage
in interface MessageHandler
message
- a messagepublic void start() throws ActiveMQException
ActiveMQException
public void failoverEvent(FailoverEventType eventType)
FailoverEventListener
failoverEvent
in interface FailoverEventListener
eventType
- The type of eventCopyright © 2016 The Apache Software Foundation. All rights reserved.