org.projectodd.wunderboss.messaging.hornetq

Class ResponseRouter

java.lang.Object

org.projectodd.wunderboss.messaging.hornetq.ResponseRouter

All Implemented Interfaces:

AutoCloseable, MessageHandler

public class ResponseRouter
extends Object
implements AutoCloseable, MessageHandler

Constructor Summary

Constructors

Constructor and Description
ResponseRouter(String id)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
String	id()
Reply	onMessage(Message msg, Context ignored)
void	registerResponse(String id, HQResponse response)
static ResponseRouter	routerFor(HQQueue queue, Codecs codecs, Options<Destination.ListenOption> options)
protected void	setEnclosingListener(Listener l)

Methods inherited from class java.lang.Object

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

Constructor Detail

ResponseRouter

public ResponseRouter(String id)

Method Detail

onMessage

public Reply onMessage(Message msg,
              Context ignored)
                throws Exception

Specified by:

onMessage in interface MessageHandler

Throws:

Exception

registerResponse

public void registerResponse(String id,
                    HQResponse response)

routerFor

public static ResponseRouter routerFor(HQQueue queue,
                       Codecs codecs,
                       Options<Destination.ListenOption> options)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

id

public String id()

setEnclosingListener

protected void setEnclosingListener(Listener l)