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.
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
CLASS_VERSION
Class version string
|
SERVICE_INFO_KEYDEFAULT_LOG_TRACE_STATUSDEFAULT_LOG_DEBUG_STATUS, DEFAULT_LOG_ERROR_STATUS, DEFAULT_LOG_INFO_STATUS, DEFAULT_LOG_WARNING_STATUS| Constructor and Description |
|---|
DataCollectorQueue() |
| Modifier and Type | Method and Description |
|---|---|
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) |
addElement, dispatchQueueElements, doStartService, doStopService, flushQueue, getElement, getInitialCapacity, getQueuedEventCount, getQueueHead, getQueueSize, getThreadCount, getTransactionManager, getTransactionsEnabled, handleDispatchError, listQueuedElements, setInitialCapacity, setThreadCount, setTransactionManager, setTransactionsEnabledaddLogListener, 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, stopServicevlogDebug, vlogDebug, vlogDebug, vlogDebug, vlogDebugTrace, vlogError, vlogError, vlogError, vlogError, vlogInfo, vlogInfo, vlogInfo, vlogInfo, vlogTrace, vlogTrace, vlogTrace, vlogTrace, vlogWarning, vlogWarning, vlogWarning, vlogWarningprotected EventQueueElement createElement()
EventQueuecreateElement in class EventQueuepublic void addDataListener(DataCollector pListener)
public void removeDataListener(DataCollector pListener)
public int getDataListenerCount()
public DataCollector[] getDataListeners()
public void setDataListeners(DataCollector[] pListeners)
public void addDataItem(java.lang.Object arg0)
DataListeneraddDataItem in interface DataListenerpublic void flush()
DataCollectorflush in interface DataCollectorprotected void dispatchElement(EventQueueElement pElem)
EventQueuedispatchElement in class EventQueue