org.objectweb.joram.mom.dest
Class MonitoringTopicImpl

java.lang.Object
  org.objectweb.joram.mom.dest.DestinationImpl
      org.objectweb.joram.mom.dest.TopicImpl
          org.objectweb.joram.mom.dest.MonitoringTopicImpl

All Implemented Interfaces:

java.io.Serializable, DestinationImplMBean, MonitoringTopicImplMBean, TopicImplMBean

public class MonitoringTopicImpl
extends TopicImpl
implements MonitoringTopicImplMBean

The MonitoringTopicImpl class implements the monitoring behavior, regularly delivering monitoring messages to subscribers.

See Also:

Serialized Form

Field Summary

protected long

period Time between two monitoring events.

Fields inherited from class org.objectweb.joram.mom.dest.TopicImpl

alreadySentLocally, fatherId, friends, selectors, subscribers

Fields inherited from class org.objectweb.joram.mom.dest.DestinationImpl

_rights, agent, clients, creationDate, dmqId, freeReading, freeWriting, logger, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, WRITE

Constructor Summary

MonitoringTopicImpl(fr.dyade.aaa.agent.AgentId adminId, java.util.Properties prop)

Method Summary

void	addMonitoredAttributes(java.lang.String MBeanName, java.lang.String attributes) Add the specified attributes to the list of monitored attributes.
void	delMonitoredAttributes(java.lang.String MBeanName) Removes all the attributes of the specified MBean in the list of monitored attributes.
java.lang.String[]	getMonitoredAttributes() Returns the comma separated list of all monitored attributes.
long	getNbMsgsReceiveSinceCreation() Returns the number of messages received since creation time of this destination.
long	getPeriod() Returns the time between two monitoring events, one minute if not set.
void	initialize(boolean firstTime) Initializes the destination.
ClientMessages	preProcess(fr.dyade.aaa.agent.AgentId from, ClientMessages msgs)
void	setPeriod(long period) Sets or unsets the period for this queue.
void	wakeUpNot(WakeUpNot not) When the topic is waken up, collect the monitoring information required and send it.

Methods inherited from class org.objectweb.joram.mom.dest.TopicImpl

clusterAck, clusterNot, clusterRequest, clusterTest, destinationAdminRequestNot, doClientMessages, doDeleteNot, doRightRequest, doUnknownAgent, fatherAck, fatherTest, forwardMessages, getSubscriberIds, monitGetCluster, monitGetFather, monitGetSubscriptions, postSubscribe, postUnsubscribe, preSubscribe, preUnsubscribe, processMessages, setAlreadySentLocally, setFatherRequest, subscribeRequest, topicForwardNot, toString, unclusterNot, unclusterRequest, unsetFatherRequest, unsubscribeRequest

Methods inherited from class org.objectweb.joram.mom.dest.DestinationImpl

canBeDeleted, clientMessages, deleteNot, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getId, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getRight, getRights, getStatisticHashtable, handleDeniedMessage, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isWriter, monitFreeAccess, monitGetDMQSettings, monitGetReaders, monitGetStat, monitGetWriters, postProcess, postProcess, preProcess, processSetRight, replyToTopic, requestGroupNot, setAgent, setDMQRequest, setFreeReading, setFreeWriting, setRightRequest, specialAdminProcess, specialAdminRequest, unknownAgent

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.objectweb.joram.mom.dest.TopicImplMBean

getSubscriberIds

Methods inherited from interface org.objectweb.joram.mom.dest.DestinationImplMBean

getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, toString

Field Detail

period

protected long period

Time between two monitoring events. One minute by default.

Constructor Detail

MonitoringTopicImpl

public MonitoringTopicImpl(fr.dyade.aaa.agent.AgentId adminId,
                           java.util.Properties prop)

Method Detail

initialize

public void initialize(boolean firstTime)

Description copied from class: TopicImpl

Initializes the destination.

Overrides:

initialize in class TopicImpl

Parameters:

firstTime - true when first called by the factory

getPeriod

public long getPeriod()

Returns the time between two monitoring events, one minute if not set.

Specified by:

getPeriod in interface MonitoringTopicImplMBean

Returns:

the period value of this queue; one minute if not set.

preProcess

public ClientMessages preProcess(fr.dyade.aaa.agent.AgentId from,
                                 ClientMessages msgs)

Overrides:

preProcess in class DestinationImpl

setPeriod

public void setPeriod(long period)

Sets or unsets the period for this queue.

Specified by:

setPeriod in interface MonitoringTopicImplMBean

Parameters:

period - The period value to be set or -1 for unsetting previous value.

wakeUpNot

public void wakeUpNot(WakeUpNot not)

When the topic is waken up, collect the monitoring information required and send it.

getNbMsgsReceiveSinceCreation

public long getNbMsgsReceiveSinceCreation()

Description copied from class: DestinationImpl

Returns the number of messages received since creation time of this destination.

Specified by:

getNbMsgsReceiveSinceCreation in interface DestinationImplMBean

Overrides:

getNbMsgsReceiveSinceCreation in class TopicImpl

Returns:

the number of messages received since creation time.

getMonitoredAttributes

public java.lang.String[] getMonitoredAttributes()

Returns the comma separated list of all monitored attributes.

Specified by:

getMonitoredAttributes in interface MonitoringTopicImplMBean

Returns:

the comma separated list of all monitored attributes.

addMonitoredAttributes

public void addMonitoredAttributes(java.lang.String MBeanName,
                                   java.lang.String attributes)

Add the specified attributes to the list of monitored attributes. If the Mbean is already monitored, the specified list of attributes overrides the existing one.

Specified by:

addMonitoredAttributes in interface MonitoringTopicImplMBean

Parameters:

MBeanName - the name of the MBean.

attributes - the comma separated list of attributes to monitor.

delMonitoredAttributes

public void delMonitoredAttributes(java.lang.String MBeanName)

Removes all the attributes of the specified MBean in the list of monitored attributes.

Specified by:

delMonitoredAttributes in interface MonitoringTopicImplMBean

Parameters:

MBeanName - the name of the MBean.