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, setSelector
addDestination, createDestination, getBrokerAdmin, getBrokerFacade, getJMSDestination, getJMSDestinationType, getPhysicalDestinationName, getQueueView, getSupportedHttpMethods, getValidDestination, redirectToBrowseView, redirectToDestinationView, redirectToRequest, removeDestination, setJMSDestination, setJMSDestinationType, toString
public MessageQuery(BrokerFacade brokerFacade, SessionPool sessionPool) throws JMSException
JMSException
public void setMessage(Message message)
public Message getMessage() throws JMSException
JMSException
public Object getBody() throws JMSException
JMSException
public Map<String,Object> getPropertiesMap() throws JMSException
JMSException
protected Map<String,Object> createMapBody(MapMessage mapMessage) throws JMSException
JMSException
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.