org.apache.activemq.web.controller
Class SendMessage
java.lang.Object
org.apache.activemq.web.BrokerFacade
org.apache.activemq.web.DestinationFacade
org.apache.activemq.web.controller.SendMessage
- All Implemented Interfaces:
- org.springframework.web.servlet.mvc.Controller
public class SendMessage
- extends DestinationFacade
- implements org.springframework.web.servlet.mvc.Controller
Sends a message
- Version:
- $Revision: 426366 $
Methods inherited from class org.apache.activemq.web.DestinationFacade |
addDestination, createDestination, getJMSDestination, getJMSDestinationType, getValidDestination, isQueue, redirectToBrowseView, redirectToRequest, removeDestination, setJMSDestination, setJMSDestinationType, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
SendMessage
public SendMessage(BrokerService brokerService)
handleRequest
public org.springframework.web.servlet.ModelAndView handleRequest(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response)
throws java.lang.Exception
- Specified by:
handleRequest
in interface org.springframework.web.servlet.mvc.Controller
- Throws:
java.lang.Exception
sendMessages
protected void sendMessages(javax.servlet.http.HttpServletRequest request,
WebClient client,
ActiveMQDestination dest)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getJMSCorrelationID
public java.lang.String getJMSCorrelationID()
setJMSCorrelationID
public void setJMSCorrelationID(java.lang.String correlationID)
getJMSReplyTo
public java.lang.String getJMSReplyTo()
setJMSReplyTo
public void setJMSReplyTo(java.lang.String replyTo)
getJMSType
public java.lang.String getJMSType()
setJMSType
public void setJMSType(java.lang.String type)
isJMSPersistent
public boolean isJMSPersistent()
setJMSPersistent
public void setJMSPersistent(boolean persistent)
getJMSPriority
public int getJMSPriority()
setJMSPriority
public void setJMSPriority(int priority)
getJMSText
public java.lang.String getJMSText()
setJMSText
public void setJMSText(java.lang.String text)
getJMSTimeToLive
public int getJMSTimeToLive()
setJMSTimeToLive
public void setJMSTimeToLive(int timeToLive)
getJMSMessageCount
public int getJMSMessageCount()
setJMSMessageCount
public void setJMSMessageCount(int copies)
getJMSMessageCountHeader
public java.lang.String getJMSMessageCountHeader()
setJMSMessageCountHeader
public void setJMSMessageCountHeader(java.lang.String messageCountHeader)
createMessage
protected javax.jms.Message createMessage(WebClient client,
javax.servlet.http.HttpServletRequest request)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
appendHeaders
protected void appendHeaders(javax.jms.Message message,
javax.servlet.http.HttpServletRequest request)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
isValidPropertyName
protected boolean isValidPropertyName(java.lang.String name)
Copyright © 2010 Apache Software Foundation. All Rights Reserved.