Package org.apache.activemq.web
Class MessageQuery
- java.lang.Object
-
- org.apache.activemq.web.DestinationFacade
-
- org.apache.activemq.web.QueueBrowseQuery
-
- org.apache.activemq.web.MessageQuery
-
- All Implemented Interfaces:
org.springframework.beans.factory.DisposableBean
public class MessageQuery extends QueueBrowseQuery
Allow the user to browse a message on a queue by its ID
-
-
Constructor Summary
Constructors Constructor Description MessageQuery(BrokerFacade brokerFacade)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Map<String,Object>
createMapBody(MapMessage mapMessage)
Object
getBody()
String
getId()
Message
getMessage()
Map<String,Object>
getPropertiesMap()
boolean
isDLQ()
void
setId(String id)
void
setMessage(Message message)
-
Methods inherited from class org.apache.activemq.web.QueueBrowseQuery
createBrowser, destroy, getBrowser, getQueue, getSelector, getSession, isQueue, setBrowser, setQueue, setSelector
-
Methods inherited from class org.apache.activemq.web.DestinationFacade
addDestination, createDestination, getBrokerAdmin, getBrokerFacade, getJMSDestination, getJMSDestinationType, getPhysicalDestinationName, getQueueView, getSupportedHttpMethods, getValidDestination, redirectToBrowseView, redirectToDestinationView, redirectToRequest, removeDestination, setJMSDestination, setJMSDestinationType, toString
-
-
-
-
Constructor Detail
-
MessageQuery
public MessageQuery(BrokerFacade brokerFacade) throws JMSException
- Throws:
JMSException
-
-
Method Detail
-
getId
public String getId()
-
setId
public void setId(String id)
-
setMessage
public void setMessage(Message message)
-
getMessage
public Message getMessage() throws JMSException
- Throws:
JMSException
-
getBody
public Object getBody() throws JMSException
- Throws:
JMSException
-
getPropertiesMap
public Map<String,Object> getPropertiesMap() throws JMSException
- Throws:
JMSException
-
createMapBody
protected Map<String,Object> createMapBody(MapMessage mapMessage) throws JMSException
- Throws:
JMSException
-
-