atg.service.datacollection
Class DataCollectorQueue

java.lang.Object
  atg.nucleus.logging.VariableArgumentApplicationLoggingImpl
      atg.nucleus.GenericService
          atg.service.queue.EventQueue
              atg.service.datacollection.DataCollectorQueue

All Implemented Interfaces:

atg.naming.AbsoluteNameable, NameContextBindingListener, NameContextElement, atg.naming.NameContextParentable, NameResolver, AdminableService, atg.nucleus.Configured, ApplicationLogging, atg.nucleus.logging.ApplicationLoggingSender, atg.nucleus.logging.TraceApplicationLogging, VariableArgumentApplicationLogging, ComponentNameResolver, Service, ServiceListener, DataCollector, DataListener, java.util.EventListener

public class DataCollectorQueue
extends EventQueue
implements DataCollector

This is a queueing version of the interface atg.service.datacollection.DataCollector. Calls made to this class are queued, then passed on to the listeners of this interface

This class was originally generated by atg.service.queue.EventQueueGenerator using the command java atg.service.queue.EventQueueGenerator atg.service.datacollection.DataCollector

However this queue needs to have a dataListeners array property to work properly and so it has been modified by hand.

Field Summary

static java.lang.String

CLASS_VERSION Class version string

Fields inherited from class atg.nucleus.GenericService

SERVICE_INFO_KEY

Fields inherited from interface atg.nucleus.logging.TraceApplicationLogging

DEFAULT_LOG_TRACE_STATUS

Fields inherited from interface atg.nucleus.logging.ApplicationLogging

DEFAULT_LOG_DEBUG_STATUS, DEFAULT_LOG_ERROR_STATUS, DEFAULT_LOG_INFO_STATUS, DEFAULT_LOG_WARNING_STATUS

Constructor Summary

DataCollectorQueue()

Method Summary

void	addDataItem(java.lang.Object arg0) Add the given data item to the aggregate
void	addDataListener(DataCollector pListener)
protected EventQueueElement	createElement() Constructs a new blank EventQueueElement.
protected void	dispatchElement(EventQueueElement pElem) Dispatches a Queue element to be handled.
void	flush() Flush data buffers
int	getDataListenerCount()
DataCollector[]	getDataListeners()
void	removeDataListener(DataCollector pListener)
void	setDataListeners(DataCollector[] pListeners)

Methods inherited from class atg.service.queue.EventQueue

addElement, dispatchQueueElements, doStartService, doStopService, flushQueue, getElement, getInitialCapacity, getQueuedEventCount, getQueueHead, getQueueSize, getThreadCount, getTransactionManager, getTransactionsEnabled, handleDispatchError, listQueuedElements, setInitialCapacity, setThreadCount, setTransactionManager, setTransactionsEnabled

Methods inherited from class atg.nucleus.GenericService

addLogListener, createAdminServlet, getAbsoluteName, getAdminServlet, getAdminServletOutputStreamEncoding, getLoggingForVlogging, getLogListenerCount, getLogListeners, getName, getNameContext, getNucleus, getRoot, getServiceConfiguration, getServiceInfo, isAdminServletUseServletOutputStream, isLoggingDebug, isLoggingError, isLoggingInfo, isLoggingTrace, isLoggingWarning, isRunning, logDebug, logDebug, logDebug, logError, logError, logError, logInfo, logInfo, logInfo, logTrace, logTrace, logTrace, logWarning, logWarning, logWarning, nameContextElementBound, nameContextElementUnbound, removeLogListener, reResolveThis, resolveName, resolveName, resolveName, resolveName, sendLogEvent, setAdminServletOutputStreamEncoding, setAdminServletUseServletOutputStream, setLoggingDebug, setLoggingError, setLoggingInfo, setLoggingTrace, setLoggingWarning, setNucleus, setServiceInfo, startService, stopService

Methods inherited from class atg.nucleus.logging.VariableArgumentApplicationLoggingImpl

vlogDebug, vlogDebug, vlogDebug, vlogDebug, vlogDebugTrace, vlogError, vlogError, vlogError, vlogError, vlogInfo, vlogInfo, vlogInfo, vlogInfo, vlogTrace, vlogTrace, vlogTrace, vlogTrace, vlogWarning, vlogWarning, vlogWarning, vlogWarning

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_VERSION

public static java.lang.String CLASS_VERSION

Class version string

Constructor Detail

DataCollectorQueue

public DataCollectorQueue()

Method Detail

createElement

protected EventQueueElement createElement()

Description copied from class: EventQueue

Constructs a new blank EventQueueElement. Subclasses must implement this method.

Specified by:

createElement in class EventQueue

addDataListener

public void addDataListener(DataCollector pListener)

removeDataListener

public void removeDataListener(DataCollector pListener)

getDataListenerCount

public int getDataListenerCount()

getDataListeners

public DataCollector[] getDataListeners()

setDataListeners

public void setDataListeners(DataCollector[] pListeners)

addDataItem

public void addDataItem(java.lang.Object arg0)

Description copied from interface: DataListener

Add the given data item to the aggregate

Specified by:

addDataItem in interface DataListener

flush

public void flush()

Description copied from interface: DataCollector

Flush data buffers

Specified by:

flush in interface DataCollector

dispatchElement

protected void dispatchElement(EventQueueElement pElem)

Description copied from class: EventQueue

Dispatches a Queue element to be handled. Subclasses must implement this method.

Specified by:

dispatchElement in class EventQueue