org.projectodd.wunderboss.messaging.hornetq

Class MessageHandlerGroup

java.lang.Object

org.projectodd.wunderboss.messaging.hornetq.MessageHandlerGroup

All Implemented Interfaces:

AutoCloseable, Listener

public class MessageHandlerGroup
extends Object
implements Listener

Constructor Summary

Constructors

Constructor and Description
MessageHandlerGroup(HQSpecificContext context, MessageHandler handler, Codecs codecs, HQDestination destination, Options<Destination.ListenOption> options)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected javax.jms.JMSConsumer	createConsumer(HQSpecificContext context)
MessageHandlerGroup	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageHandlerGroup

public MessageHandlerGroup(HQSpecificContext context,
                   MessageHandler handler,
                   Codecs codecs,
                   HQDestination destination,
                   Options<Destination.ListenOption> options)

Method Detail

start

public MessageHandlerGroup start()
                          throws Exception

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

createConsumer

protected javax.jms.JMSConsumer createConsumer(HQSpecificContext context)
                                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException