org.projectodd.wunderboss.messaging.hornetq

Class HQMessage

java.lang.Object

org.projectodd.wunderboss.messaging.hornetq.HQMessage

All Implemented Interfaces:

Message, ReplyableMessage

public class HQMessage
extends Object
implements ReplyableMessage

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONTENT_TYPE_PROPERTY
protected static String	REQUEST_ID_PROPERTY
protected static String	REQUEST_NODE_ID_PROPERTY
protected static String	SYNC_PROPERTY
protected static String	SYNC_RESPONSE_PROPERTY

Method Summary

Methods

Modifier and Type	Method and Description
boolean	acknowledge()
Object	body()
String	contentType()
static String	contentType(javax.jms.Message message)
Destination	endpoint()
String	id()
javax.jms.Message	jmsMessage()
protected String	nodeID()
Map<String,Object>	properties()
void	reply(Object content, Codec codec, Map<Destination.MessageOpOption,Object> options)
protected Options<Destination.MessageOpOption>	replyOptions(Map<Destination.MessageOpOption,Object> options)
protected String	requestID()

Methods inherited from class java.lang.Object

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

Field Detail

CONTENT_TYPE_PROPERTY

public static final String CONTENT_TYPE_PROPERTY

See Also:

Constant Field Values

SYNC_PROPERTY

protected static final String SYNC_PROPERTY

See Also:

Constant Field Values

SYNC_RESPONSE_PROPERTY

protected static final String SYNC_RESPONSE_PROPERTY

See Also:

Constant Field Values

REQUEST_ID_PROPERTY

protected static final String REQUEST_ID_PROPERTY

See Also:

Constant Field Values

REQUEST_NODE_ID_PROPERTY

protected static final String REQUEST_NODE_ID_PROPERTY

See Also:

Constant Field Values

Method Detail

id

public String id()

Specified by:

id in interface Message

contentType

public String contentType()

Specified by:

contentType in interface Message

contentType

public static String contentType(javax.jms.Message message)

properties

public Map<String,Object> properties()

Specified by:

properties in interface Message

endpoint

public Destination endpoint()

Specified by:

endpoint in interface Message

body

public Object body()

Specified by:

body in interface Message

acknowledge

public boolean acknowledge()
                    throws Exception

Specified by:

acknowledge in interface Message

Throws:

Exception

reply

public void reply(Object content,
         Codec codec,
         Map<Destination.MessageOpOption,Object> options)
           throws Exception

Specified by:

reply in interface ReplyableMessage

Throws:

Exception

requestID

protected String requestID()

nodeID

protected String nodeID()

replyOptions

protected Options<Destination.MessageOpOption> replyOptions(Map<Destination.MessageOpOption,Object> options)
                                                     throws Exception

Throws:

Exception

jmsMessage

public javax.jms.Message jmsMessage()