ClientMonitorInterceptor

Overview

Package

Class

Tree

Deprecated

Index

Help

PREV CLASS (src) NEXT CLASS (src)

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.jboss.mq.server
Class ClientMonitorInterceptor

java.lang.Object
  org.jboss.mq.server.JMSServerInterceptorSupport (src) 
      org.jboss.mq.server.ClientMonitorInterceptor

All Implemented Interfaces:: JMSServerInterceptor (src)

public class ClientMonitorInterceptor
extends JMSServerInterceptorSupport (src)

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.

Field Summary
`protected static Logger (src)`	`log`

Fields inherited from class org.jboss.mq.server.JMSServerInterceptorSupport (src)

nextInterceptor

Constructor Summary
`ClientMonitorInterceptor()`

Method Summary
`void`	`acknowledge(ConnectionToken (src) dc, AcknowledgementRequest (src) item)` #Description of the Method
`void`	`addMessage(ConnectionToken (src) dc, SpyMessage (src) message)` Add the message to the destination.
`SpyMessage (src) []`	`browse(ConnectionToken (src) dc, Destination (src) dest, java.lang.String selector)` #Description of the Method
`void`	`connectionClosing(ConnectionToken (src) dc)` #Description of the Method
`Queue (src)`	`createQueue(ConnectionToken (src) dc, java.lang.String dest)` #Description of the Method
`Topic (src)`	`createTopic(ConnectionToken (src) dc, java.lang.String dest)` #Description of the Method
`void`	`deleteTemporaryDestination(ConnectionToken (src) dc, SpyDestination (src) dest)` #Description of the Method
`void`	`destroySubscription(ConnectionToken (src) dc, DurableSubscriptionID (src) id)` #Description of the Method
`void`	`disconnectInactiveClients(long disconnectTime)`
`org.jboss.mq.server.ClientMonitorInterceptor.ClientStats`	`getClientStats(ConnectionToken (src) dc)`
`Subscription (src)`	`getSubscription(ConnectionToken (src) dc, int subscriberId)` Get the subscription that match the id.
`TemporaryQueue (src)`	`getTemporaryQueue(ConnectionToken (src) dc)` Gets the TemporaryQueue attribute of the ServerIL object
`TemporaryTopic (src)`	`getTemporaryTopic(ConnectionToken (src) dc)` Gets the TemporaryTopic attribute of the ServerIL object
`void`	`ping(ConnectionToken (src) dc, long clientTime)` #Description of the Method
`SpyMessage (src)`	`receive(ConnectionToken (src) dc, int subscriberId, long wait)` #Description of the Method
`void`	`setEnabled(ConnectionToken (src) dc, boolean enabled)` Sets the Enabled attribute of the ServerIL object
`void`	`subscribe(ConnectionToken (src) dc, Subscription (src) s)`
`void`	`transact(ConnectionToken (src) dc, TransactionRequest (src) t)` #Description of the Method
`void`	`unsubscribe(ConnectionToken (src) dc, int subscriptionId)` #Description of the Method

Methods inherited from class org.jboss.mq.server.JMSServerInterceptorSupport (src)

authenticate, checkID, checkUser, getDurableTopic, getID, getNext, getThreadGroup, setNext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected static Logger (src)  log

Constructor Detail

ClientMonitorInterceptor

public ClientMonitorInterceptor()

Method Detail

disconnectInactiveClients

public void disconnectInactiveClients(long disconnectTime)

getClientStats

public org.jboss.mq.server.ClientMonitorInterceptor.ClientStats getClientStats(ConnectionToken (src)  dc)
                                                                        throws JMSException (src)

Throws:: JMSException (src)

getTemporaryTopic

public TemporaryTopic (src)  getTemporaryTopic(ConnectionToken (src)  dc)
                                 throws JMSException (src)

Description copied from class: JMSServerInterceptorSupport (src)

Gets the TemporaryTopic attribute of the ServerIL object

Specified by:: getTemporaryTopic in interface JMSServerInterceptor (src)
Overrides:: getTemporaryTopic in class JMSServerInterceptorSupport (src)

Parameters:: dc - Description of Parameter
Returns:: The TemporaryTopic value
Throws:: JMSException (src) - Description of Exception

getTemporaryQueue

public TemporaryQueue (src)  getTemporaryQueue(ConnectionToken (src)  dc)
                                 throws JMSException (src)

Gets the TemporaryQueue attribute of the ServerIL object

Specified by:: getTemporaryQueue in interface JMSServerInterceptor (src)
Overrides:: getTemporaryQueue in class JMSServerInterceptorSupport (src)

Parameters:: dc - Description of Parameter
Returns:: The TemporaryQueue value
Throws:: JMSException (src) - Description of Exception

connectionClosing

public void connectionClosing(ConnectionToken (src)  dc)
                       throws JMSException (src)

#Description of the Method

Specified by:: connectionClosing in interface JMSServerInterceptor (src)
Overrides:: connectionClosing in class JMSServerInterceptorSupport (src)

Parameters:: dc - Description of Parameter
Throws:: JMSException (src) - Description of Exception

addMessage

public void addMessage(ConnectionToken (src)  dc,
                       SpyMessage (src)  message)
                throws JMSException (src)

Add the message to the destination.

Specified by:: addMessage in interface JMSServerInterceptor (src)
Overrides:: addMessage in class JMSServerInterceptorSupport (src)

Parameters:: dc - The feature to be added to the Message attribute; message - The feature to be added to the Message attribute
Throws:: JMSException (src) - Description of Exception

createQueue

public Queue (src)  createQueue(ConnectionToken (src)  dc,
                         java.lang.String dest)
                  throws JMSException (src)

#Description of the Method

Specified by:: createQueue in interface JMSServerInterceptor (src)
Overrides:: createQueue in class JMSServerInterceptorSupport (src)

Parameters:: dc - Description of Parameter; dest - Description of Parameter
Returns:: Description of the Returned Value
Throws:: JMSException (src) - Description of Exception

createTopic

public Topic (src)  createTopic(ConnectionToken (src)  dc,
                         java.lang.String dest)
                  throws JMSException (src)

#Description of the Method

Specified by:: createTopic in interface JMSServerInterceptor (src)
Overrides:: createTopic in class JMSServerInterceptorSupport (src)

Parameters:: dc - Description of Parameter; dest - Description of Parameter
Returns:: Description of the Returned Value
Throws:: JMSException (src) - Description of Exception

deleteTemporaryDestination

public void deleteTemporaryDestination(ConnectionToken (src)  dc,
                                       SpyDestination (src)  dest)
                                throws JMSException (src)

#Description of the Method

Specified by:: deleteTemporaryDestination in interface JMSServerInterceptor (src)
Overrides:: deleteTemporaryDestination in class JMSServerInterceptorSupport (src)

Parameters:: dc - Description of Parameter; dest - Description of Parameter
Throws:: JMSException (src) - Description of Exception

transact

public void transact(ConnectionToken (src)  dc,
                     TransactionRequest (src)  t)
              throws JMSException (src)

#Description of the Method

Specified by:: transact in interface JMSServerInterceptor (src)
Overrides:: transact in class JMSServerInterceptorSupport (src)

Parameters:: dc - Description of Parameter; t - Description of Parameter
Throws:: JMSException (src) - Description of Exception

acknowledge

public void acknowledge(ConnectionToken (src)  dc,
                        AcknowledgementRequest (src)  item)
                 throws JMSException (src)

#Description of the Method

Specified by:: acknowledge in interface JMSServerInterceptor (src)
Overrides:: acknowledge in class JMSServerInterceptorSupport (src)

Parameters:: dc - Description of Parameter; item - Description of Parameter
Throws:: JMSException (src) - Description of Exception

browse

public SpyMessage (src) [] browse(ConnectionToken (src)  dc,
                           Destination (src)  dest,
                           java.lang.String selector)
                    throws JMSException (src)

#Description of the Method

Specified by:: browse in interface JMSServerInterceptor (src)
Overrides:: browse in class JMSServerInterceptorSupport (src)

Parameters:: dc - Description of Parameter; dest - Description of Parameter; selector - Description of Parameter
Returns:: Description of the Returned Value
Throws:: JMSException (src) - Description of Exception

receive

public SpyMessage (src)  receive(ConnectionToken (src)  dc,
                          int subscriberId,
                          long wait)
                   throws JMSException (src)

#Description of the Method

Specified by:: receive in interface JMSServerInterceptor (src)
Overrides:: receive in class JMSServerInterceptorSupport (src)

Parameters:: dc - Description of Parameter; subscriberId - Description of Parameter; wait - Description of Parameter
Returns:: Description of the Returned Value
Throws:: JMSException (src) - Description of Exception

setEnabled

public void setEnabled(ConnectionToken (src)  dc,
                       boolean enabled)
                throws JMSException (src)

Sets the Enabled attribute of the ServerIL object

Specified by:: setEnabled in interface JMSServerInterceptor (src)
Overrides:: setEnabled in class JMSServerInterceptorSupport (src)

Parameters:: dc - The new Enabled value; enabled - The new Enabled value
Throws:: JMSException (src) - Description of Exception

unsubscribe

public void unsubscribe(ConnectionToken (src)  dc,
                        int subscriptionId)
                 throws JMSException (src)

#Description of the Method

Specified by:: unsubscribe in interface JMSServerInterceptor (src)
Overrides:: unsubscribe in class JMSServerInterceptorSupport (src)

Parameters:: dc - Description of Parameter; subscriptionId - Description of Parameter
Throws:: JMSException (src) - Description of Exception

destroySubscription

public void destroySubscription(ConnectionToken (src)  dc,
                                DurableSubscriptionID (src)  id)
                         throws JMSException (src)

#Description of the Method

Specified by:: destroySubscription in interface JMSServerInterceptor (src)
Overrides:: destroySubscription in class JMSServerInterceptorSupport (src)

Parameters:: id - Description of Parameter
Throws:: JMSException (src) - Description of Exception

public void subscribe(ConnectionToken (src)  dc,
                      Subscription (src)  s)
               throws JMSException (src)

Specified by:: subscribe in interface JMSServerInterceptor (src)
Overrides:: subscribe in class JMSServerInterceptorSupport (src)

Parameters:: dc - org.jboss.mq.ConnectionToken; s - org.jboss.mq.Subscription
Throws:: JMSException (src) - The exception description.

ping

public void ping(ConnectionToken (src)  dc,
                 long clientTime)
          throws JMSException (src)

#Description of the Method

Specified by:: ping in interface JMSServerInterceptor (src)
Overrides:: ping in class JMSServerInterceptorSupport (src)

Parameters:: dc - Description of Parameter; clientTime - Description of Parameter
Throws:: JMSException (src) - Description of Exception

getSubscription

public Subscription (src)  getSubscription(ConnectionToken (src)  dc,
                                    int subscriberId)
                             throws JMSException (src)

Description copied from interface: JMSServerInterceptor (src)

Get the subscription that match the id.