public class MessageQuery extends QueueBrowseQuery
Constructor and Description |
---|
MessageQuery(BrokerFacade brokerFacade,
SessionPool sessionPool) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,Object> |
createMapBody(javax.jms.MapMessage mapMessage) |
Object |
getBody() |
String |
getId() |
javax.jms.Message |
getMessage() |
Map<String,Object> |
getPropertiesMap() |
void |
setId(String id) |
void |
setMessage(javax.jms.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 javax.jms.JMSException
javax.jms.JMSException
public void setMessage(javax.jms.Message message)
public javax.jms.Message getMessage() throws javax.jms.JMSException
javax.jms.JMSException
public Map<String,Object> getPropertiesMap() throws javax.jms.JMSException
javax.jms.JMSException
protected Map<String,Object> createMapBody(javax.jms.MapMessage mapMessage) throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.