| java.lang.Object org.jboss.mq.server.JMSServerInterceptorSupport org.jboss.mq.server.ClientMonitorInterceptor
ClientMonitorInterceptor | public class ClientMonitorInterceptor extends JMSServerInterceptorSupport (Code) | | A pass through Interceptor, which keeps track of when a
client was last active. If a client is inactive for too long,
then it is disconnected from the server.
This is only necessary for stateless transports like HTTP
author: Hiram Chirino author: adrian@jboss.org |
Field Summary | |
ConcurrentReaderHashMap | clients |
Method Summary | |
public void | acknowledge(ConnectionToken dc, AcknowledgementRequest item) | public void | addMessage(ConnectionToken dc, SpyMessage message) | public SpyMessage[] | browse(ConnectionToken dc, Destination dest, String selector) | public void | connectionClosing(ConnectionToken dc) | public Queue | createQueue(ConnectionToken dc, String dest) | public Topic | createTopic(ConnectionToken dc, String dest) | public void | deleteTemporaryDestination(ConnectionToken dc, SpyDestination dest) | public void | destroySubscription(ConnectionToken dc, DurableSubscriptionID id) | public void | disconnectInactiveClients(long disconnectTime) | public ClientStats | getClientStats(ConnectionToken dc) | public Subscription | getSubscription(ConnectionToken dc, int subscriberId) | public TemporaryQueue | getTemporaryQueue(ConnectionToken dc) | public TemporaryTopic | getTemporaryTopic(ConnectionToken dc) | public ClientStats | peekClientStats(ConnectionToken dc) Peek the stats. | public void | ping(ConnectionToken dc, long clientTime) | public SpyMessage | receive(ConnectionToken dc, int subscriberId, long wait) | public void | setEnabled(ConnectionToken dc, boolean enabled) | public void | subscribe(org.jboss.mq.ConnectionToken dc, org.jboss.mq.Subscription s) | public void | transact(ConnectionToken dc, TransactionRequest t) | public void | unsubscribe(ConnectionToken dc, int subscriptionId) |
clients | ConcurrentReaderHashMap clients(Code) | | |
disconnectInactiveClients | public void disconnectInactiveClients(long disconnectTime)(Code) | | |
peekClientStats | public ClientStats peekClientStats(ConnectionToken dc)(Code) | | Peek the stats. For testing.
Parameters: dc - the connection token the stats |
Methods inherited from org.jboss.mq.server.JMSServerInterceptorSupport | public void acknowledge(ConnectionToken dc, AcknowledgementRequest item) throws JMSException(Code)(Java Doc) public void addMessage(ConnectionToken dc, SpyMessage message) throws JMSException(Code)(Java Doc) public String authenticate(String userName, String password) throws JMSException(Code)(Java Doc) public SpyMessage[] browse(ConnectionToken dc, Destination dest, String selector) throws JMSException(Code)(Java Doc) public void checkID(String ID) throws JMSException(Code)(Java Doc) public String checkUser(String userName, String password) throws JMSException(Code)(Java Doc) public void connectionClosing(ConnectionToken dc) throws JMSException(Code)(Java Doc) public Queue createQueue(ConnectionToken dc, String dest) throws JMSException(Code)(Java Doc) public Topic createTopic(ConnectionToken dc, String dest) throws JMSException(Code)(Java Doc) public void deleteTemporaryDestination(ConnectionToken dc, SpyDestination dest) throws JMSException(Code)(Java Doc) public void destroySubscription(ConnectionToken dc, DurableSubscriptionID id) throws JMSException(Code)(Java Doc) public SpyTopic getDurableTopic(DurableSubscriptionID sub) throws JMSException(Code)(Java Doc) public String getID() throws JMSException(Code)(Java Doc) public JMSServerInterceptor getNext()(Code)(Java Doc) public Subscription getSubscription(ConnectionToken dc, int subscriberId) throws JMSException(Code)(Java Doc) public TemporaryQueue getTemporaryQueue(ConnectionToken dc) throws JMSException(Code)(Java Doc) public TemporaryTopic getTemporaryTopic(ConnectionToken dc) throws JMSException(Code)(Java Doc) public ThreadGroup getThreadGroup()(Code)(Java Doc) public void ping(ConnectionToken dc, long clientTime) throws JMSException(Code)(Java Doc) public SpyMessage receive(ConnectionToken dc, int subscriberId, long wait) throws JMSException(Code)(Java Doc) public Xid[] recover(ConnectionToken dc, int flags) throws Exception(Code)(Java Doc) public void setEnabled(ConnectionToken dc, boolean enabled) throws JMSException(Code)(Java Doc) public void setNext(JMSServerInterceptor server)(Code)(Java Doc) public void subscribe(org.jboss.mq.ConnectionToken dc, org.jboss.mq.Subscription s) throws JMSException(Code)(Java Doc) public void transact(ConnectionToken dc, TransactionRequest t) throws JMSException(Code)(Java Doc) public void unsubscribe(ConnectionToken dc, int subscriptionId) throws JMSException(Code)(Java Doc)
|
|
|