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 |
---|---|
Thread |
interruptConsumer(FutureLatch future) |
void |
onMessage(ClientMessage message) |
void |
setup() |
void |
start() |
void |
teardown()
Stop the handler
|
public HornetQMessageHandler(HornetQActivation activation, TransactionManager tm, ClientSessionInternal session, ClientSessionFactory cf, int sessionNr)
public Thread interruptConsumer(FutureLatch future)
public void teardown()
public void onMessage(ClientMessage message)
onMessage
in interface MessageHandler
public void start() throws HornetQException
HornetQException
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.