public class MessageQuery extends QueueBrowseQuery
| Constructor and Description |
|---|
MessageQuery(BrokerFacade brokerFacade,
SessionPool sessionPool) |
| Modifier and Type | Method and Description |
|---|---|
protected Map<String,Object> |
createMapBody(MapMessage mapMessage) |
Object |
getBody() |
String |
getId() |
Message |
getMessage() |
Map<String,Object> |
getPropertiesMap() |
void |
setId(String id) |
void |
setMessage(Message message) |
createBrowser, destroy, getBrowser, getQueue, getSelector, getSession, isQueue, setBrowser, setQueue, setSelectoraddDestination, createDestination, getBrokerAdmin, getBrokerFacade, getJMSDestination, getJMSDestinationType, getPhysicalDestinationName, getQueueView, getSupportedHttpMethods, getValidDestination, redirectToBrowseView, redirectToDestinationView, redirectToRequest, removeDestination, setJMSDestination, setJMSDestinationType, toStringpublic MessageQuery(BrokerFacade brokerFacade, SessionPool sessionPool) throws JMSException
JMSExceptionpublic void setMessage(Message message)
public Message getMessage() throws JMSException
JMSExceptionpublic Object getBody() throws JMSException
JMSExceptionpublic Map<String,Object> getPropertiesMap() throws JMSException
JMSExceptionprotected Map<String,Object> createMapBody(MapMessage mapMessage) throws JMSException
JMSExceptionCopyright © 2005–2016 FuseSource, Corp.. All rights reserved.