org.hornetq.ra.inflow

Class HornetQMessageHandler

java.lang.Object

org.hornetq.ra.inflow.HornetQMessageHandler

All Implemented Interfaces:

MessageHandler

public class HornetQMessageHandler
extends Object
implements MessageHandler

The message handler

Author:

Adrian Brock, Jesper Pedersen, Andy Taylor

Constructor Summary

Constructors

Constructor and Description
HornetQMessageHandler(HornetQActivation activation, TransactionManager tm, ClientSessionInternal session, ClientSessionFactory cf, int sessionNr)

Method Summary

Modifier and Type	Method and Description
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

Methods inherited from class java.lang.Object

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

Constructor Detail

HornetQMessageHandler

public HornetQMessageHandler(HornetQActivation activation,
                             TransactionManager tm,
                             ClientSessionInternal session,
                             ClientSessionFactory cf,
                             int sessionNr)

Method Detail

setup

public void setup()
           throws Exception

Throws:

Exception

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

start

public void start()
           throws HornetQException

Throws:

HornetQException