public class HornetQMessageHandler extends Object implements MessageHandler
Constructor and Description |
---|
HornetQMessageHandler(HornetQActivation activation,
TransactionManager tm,
ClientSessionInternal session,
ClientSessionFactory cf,
int sessionNr) |
Modifier and Type | Method and Description |
---|---|
void |
interruptConsumer() |
void |
onMessage(ClientMessage message)
Notifies the MessageHandler that a message has been received.
|
void |
setup() |
void |
start() |
void |
teardown()
Stop the handler
|
public HornetQMessageHandler(HornetQActivation activation, TransactionManager tm, ClientSessionInternal session, ClientSessionFactory cf, int sessionNr)
public void interruptConsumer()
public void teardown()
public void onMessage(ClientMessage message)
MessageHandler
onMessage
in interface MessageHandler
message
- a messagepublic void start() throws HornetQException
HornetQException
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.