org.apache.activemq.web
Class WebClient
java.lang.Object
org.apache.activemq.web.WebClient
- All Implemented Interfaces:
- Externalizable, Serializable, EventListener, HttpSessionActivationListener, HttpSessionBindingListener
public class WebClient
- extends Object
- implements HttpSessionActivationListener, HttpSessionBindingListener, Externalizable
Represents a messaging client used from inside a web container typically
stored inside a HttpSession TODO controls to prevent DOS attacks with users
requesting many consumers TODO configure consumers with small prefetch.
- Version:
- $Revision: 1.1.1.1 $
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
WEB_CLIENT_ATTRIBUTE
public static final String WEB_CLIENT_ATTRIBUTE
- See Also:
- Constant Field Values
CONNECTION_FACTORY_ATTRIBUTE
public static final String CONNECTION_FACTORY_ATTRIBUTE
- See Also:
- Constant Field Values
CONNECTION_FACTORY_PREFETCH_PARAM
public static final String CONNECTION_FACTORY_PREFETCH_PARAM
- See Also:
- Constant Field Values
CONNECTION_FACTORY_OPTIMIZE_ACK_PARAM
public static final String CONNECTION_FACTORY_OPTIMIZE_ACK_PARAM
- See Also:
- Constant Field Values
BROKER_URL_INIT_PARAM
public static final String BROKER_URL_INIT_PARAM
- See Also:
- Constant Field Values
WebClient
public WebClient()
getWebClient
public static WebClient getWebClient(HttpServletRequest request)
- Helper method to get the client for the current session, lazily creating
a client if there is none currently
- Parameters:
request
- is the current HTTP request
- Returns:
- the current client or a newly creates
getWebClient
public static WebClient getWebClient(HttpSession session)
- Returns:
- the web client for the current HTTP session or null if there is
not a web client created yet
initContext
public static void initContext(ServletContext context)
getDeliveryMode
public int getDeliveryMode()
setDeliveryMode
public void setDeliveryMode(int deliveryMode)
closeConsumers
public void closeConsumers()
close
public void close()
isClosed
public boolean isClosed()
writeExternal
public void writeExternal(ObjectOutput out)
throws IOException
- Specified by:
writeExternal
in interface Externalizable
- Throws:
IOException
readExternal
public void readExternal(ObjectInput in)
throws IOException,
ClassNotFoundException
- Specified by:
readExternal
in interface Externalizable
- Throws:
IOException
ClassNotFoundException
send
public void send(Destination destination,
Message message)
throws JMSException
- Throws:
JMSException
send
public void send(Destination destination,
Message message,
boolean persistent,
int priority,
long timeToLive)
throws JMSException
- Throws:
JMSException
getSession
public Session getSession()
throws JMSException
- Throws:
JMSException
getConnection
public Connection getConnection()
throws JMSException
- Throws:
JMSException
initConnectionFactory
protected static void initConnectionFactory(ServletContext servletContext)
getCamelContext
public org.apache.camel.CamelContext getCamelContext()
getProducerTemplate
public org.apache.camel.ProducerTemplate getProducerTemplate()
throws Exception
- Throws:
Exception
getProducer
public MessageProducer getProducer()
throws JMSException
- Throws:
JMSException
setProducer
public void setProducer(MessageProducer producer)
getConsumer
public MessageConsumer getConsumer(Destination destination)
throws JMSException
- Throws:
JMSException
getConsumer
public MessageConsumer getConsumer(Destination destination,
boolean create)
throws JMSException
- Throws:
JMSException
closeConsumer
public void closeConsumer(Destination destination)
throws JMSException
- Throws:
JMSException
getConsumers
public List<MessageConsumer> getConsumers()
createSession
protected Session createSession()
throws JMSException
- Throws:
JMSException
getSemaphore
public Semaphore getSemaphore()
sessionWillPassivate
public void sessionWillPassivate(HttpSessionEvent event)
- Specified by:
sessionWillPassivate
in interface HttpSessionActivationListener
sessionDidActivate
public void sessionDidActivate(HttpSessionEvent event)
- Specified by:
sessionDidActivate
in interface HttpSessionActivationListener
valueBound
public void valueBound(HttpSessionBindingEvent event)
- Specified by:
valueBound
in interface HttpSessionBindingListener
valueUnbound
public void valueUnbound(HttpSessionBindingEvent event)
- Specified by:
valueUnbound
in interface HttpSessionBindingListener
createWebClient
protected static WebClient createWebClient(HttpServletRequest request)
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.