org.apache.activemq.web
Class WebClient
java.lang.Object
org.apache.activemq.web.WebClient
- All Implemented Interfaces:
- java.io.Externalizable, java.io.Serializable, java.util.EventListener, javax.servlet.http.HttpSessionActivationListener, javax.servlet.http.HttpSessionBindingListener
public class WebClient
- extends java.lang.Object
- implements javax.servlet.http.HttpSessionActivationListener, javax.servlet.http.HttpSessionBindingListener, java.io.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 |
webClientAttribute
public static final java.lang.String webClientAttribute
- See Also:
- Constant Field Values
connectionFactoryAttribute
public static final java.lang.String connectionFactoryAttribute
- See Also:
- Constant Field Values
connectionFactoryPrefetchParam
public static final java.lang.String connectionFactoryPrefetchParam
- See Also:
- Constant Field Values
connectionFactoryOptimizeAckParam
public static final java.lang.String connectionFactoryOptimizeAckParam
- See Also:
- Constant Field Values
brokerUrlInitParam
public static final java.lang.String brokerUrlInitParam
- See Also:
- Constant Field Values
WebClient
public WebClient()
getWebClient
public static WebClient getWebClient(javax.servlet.http.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(javax.servlet.http.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(javax.servlet.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(java.io.ObjectOutput out)
throws java.io.IOException
- Specified by:
writeExternal
in interface java.io.Externalizable
- Throws:
java.io.IOException
readExternal
public void readExternal(java.io.ObjectInput in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Specified by:
readExternal
in interface java.io.Externalizable
- Throws:
java.io.IOException
java.lang.ClassNotFoundException
send
public void send(javax.jms.Destination destination,
javax.jms.Message message)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
send
public void send(javax.jms.Destination destination,
javax.jms.Message message,
boolean persistent,
int priority,
int timeToLive)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getSession
public javax.jms.Session getSession()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getConnection
public ActiveMQConnection getConnection()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
initConnectionFactory
public static void initConnectionFactory(javax.servlet.ServletContext servletContext)
getProducer
public javax.jms.MessageProducer getProducer()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
setProducer
public void setProducer(javax.jms.MessageProducer producer)
getConsumer
public javax.jms.MessageConsumer getConsumer(javax.jms.Destination destination)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getConsumer
public javax.jms.MessageConsumer getConsumer(javax.jms.Destination destination,
boolean create)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
closeConsumer
public void closeConsumer(javax.jms.Destination destination)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getConsumers
public java.util.List getConsumers()
createSession
protected ActiveMQSession createSession()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getSemaphore
public edu.emory.mathcs.backport.java.util.concurrent.Semaphore getSemaphore()
sessionWillPassivate
public void sessionWillPassivate(javax.servlet.http.HttpSessionEvent event)
- Specified by:
sessionWillPassivate
in interface javax.servlet.http.HttpSessionActivationListener
sessionDidActivate
public void sessionDidActivate(javax.servlet.http.HttpSessionEvent event)
- Specified by:
sessionDidActivate
in interface javax.servlet.http.HttpSessionActivationListener
valueBound
public void valueBound(javax.servlet.http.HttpSessionBindingEvent event)
- Specified by:
valueBound
in interface javax.servlet.http.HttpSessionBindingListener
valueUnbound
public void valueUnbound(javax.servlet.http.HttpSessionBindingEvent event)
- Specified by:
valueUnbound
in interface javax.servlet.http.HttpSessionBindingListener
createWebClient
protected static WebClient createWebClient(javax.servlet.http.HttpServletRequest request)
Copyright © 2011 Apache Software Foundation. All Rights Reserved.