You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by sc...@apache.org on 2008/01/08 15:38:51 UTC
svn commit: r610003 [7/7] - in
/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src: ./ main/
main/java/ main/java/org/ main/java/org/apache/ main/java/org/apache/uima/
main/java/org/apache/uima/aae/ main/java/org/apache/uima/aae/client/
main/java/o...
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServiceInfo.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServiceInfo.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServiceInfo.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServiceInfo.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,54 @@
+package org.apache.uima.aae.jmx;
+
+public class ServiceInfo implements ServiceInfoMBean
+{
+ /**
+ *
+ */
+// private static final long serialVersionUID = -4662094240276750977L;
+ private static final String label="Service Info";
+ private String brokerURL="";
+ private String inputQueueName="";
+ private String state="";
+ private String[] deploymentDescriptor= new String[] {""};
+
+ public String getLabel()
+ {
+ return label;
+ }
+ public String getBrokerURL()
+ {
+ return brokerURL;
+ }
+
+ public String[] getDeploymentDescriptor()
+ {
+ return deploymentDescriptor;
+ }
+ public void setDeploymentDescriptor(String deploymentDescriptor)
+ {
+ this.deploymentDescriptor[0] = deploymentDescriptor;
+ }
+ public void setBrokerURL(String aBrokerURL)
+ {
+ brokerURL = aBrokerURL;
+ }
+ public String getInputQueueName()
+ {
+ return inputQueueName;
+ }
+ public void setInputQueueName( String anInputQueueName)
+ {
+ inputQueueName = anInputQueueName;
+ }
+ public String getState()
+ {
+ return state;
+ }
+ public void setState( String aState )
+ {
+ state = aState;
+ }
+
+
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServiceInfoMBean.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServiceInfoMBean.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServiceInfoMBean.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServiceInfoMBean.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,11 @@
+package org.apache.uima.aae.jmx;
+
+import java.io.Serializable;
+
+public interface ServiceInfoMBean extends Serializable
+{
+ public String getState();
+ public String getInputQueueName();
+ public String getBrokerURL();
+ public String[] getDeploymentDescriptor();
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformance.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformance.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformance.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformance.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,83 @@
+package org.apache.uima.aae.jmx;
+
+import java.text.DecimalFormat;
+import java.text.FieldPosition;
+import java.util.Formatter;
+
+
+public class ServicePerformance implements ServicePerformanceMBean
+{
+ private static final long serialVersionUID = 1L;
+ private static final String label="Service Performance";
+ private long accumulatedIdleTime=0;
+ private long numberOfCASesProcessed=0;
+ private long casDeserializationTime=0;
+ private long casSerializationTime=0;
+
+ private Object sem = new Object();
+
+ public String getLabel()
+ {
+ return label;
+ }
+
+ public void reset()
+ {
+ accumulatedIdleTime = 0;
+ numberOfCASesProcessed=0;
+ casDeserializationTime=0;
+ casSerializationTime=0;
+ }
+ public double getIdleTime()
+ {
+ if ( accumulatedIdleTime != 0)
+ synchronized( sem )
+ {
+ return((double)accumulatedIdleTime/(double) 1000000);
+ }
+ else
+ return 0;
+ }
+
+ public void incrementIdleTime(long anIdleTime)
+ {
+ synchronized( sem )
+ {
+ accumulatedIdleTime += anIdleTime;
+ }
+ }
+
+ public long getNumberOfCASesProcessed()
+ {
+ return numberOfCASesProcessed;
+ }
+
+ public synchronized void incrementNumberOfCASesProcessed()
+ {
+ numberOfCASesProcessed++;
+ }
+
+ public double getCasDeserializationTime()
+ {
+ if ( casDeserializationTime > 0 )
+ {
+ return ((double)casDeserializationTime/(double) 1000000);
+ }
+ return 0.0;
+ }
+
+ public synchronized void incrementCasDeserializationTime(long aCasDeserializationTime)
+ {
+ casDeserializationTime += aCasDeserializationTime;
+ }
+ public double getCasSerializationTime()
+ {
+ return casSerializationTime;
+ }
+
+ public synchronized void incrementCasSerializationTime(long casSerializationTime)
+ {
+ this.casSerializationTime += casSerializationTime;
+ }
+
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformanceMBean.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformanceMBean.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformanceMBean.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformanceMBean.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,16 @@
+package org.apache.uima.aae.jmx;
+
+import java.io.Serializable;
+
+
+public interface ServicePerformanceMBean extends Serializable
+{
+ public double getIdleTime();
+
+ public void reset();
+
+ public long getNumberOfCASesProcessed();
+ public double getCasDeserializationTime();
+ public double getCasSerializationTime();
+
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/AsynchAEMessage.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/AsynchAEMessage.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/AsynchAEMessage.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/AsynchAEMessage.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,58 @@
+package org.apache.uima.aae.message;
+
+public interface AsynchAEMessage
+{
+ public static final String TotalTimeSpentInAnalytic = "TimeInAnalytic";
+ public static final String SendTime = "SendTime";
+ public static final String TimeInService = "TimeInService";
+ public static final String Endpoint = "Endpoint";
+ public static final String DelegateStats = "DelegateStats";
+ public static final String RequestFailed = "RequestFailed";
+
+ public static final String CasReference = "CasReference";
+ public static final String InputCasReference = "InputCasReference";
+// public static final String CasReferenceId = "CasReferenceId";
+ public static final String MessageFrom = "MessageFrom";
+ public static final String XCASREFId = "XCASRefId";
+ public static final String XCas = "XCas";
+ public static final String AEMetadata = "Metadata";
+ public static final String CasSequence = "CasSequence";
+ public static final String ReplyToEndpoint = "ReplyToEndpoint";
+
+ public static final String RemoveEndpoint = "RemoveEndpoint";
+ public static final String Aborted = "Aborted";
+
+ public static final String TimeToSerializeCAS = "TimeToSerializeCAS";
+ public static final String TimeToDeserializeCAS = "TimeToDeserializeCAS";
+ public static final String TimeWaitingForCAS = "TimeWaitingForCAS";
+ public static final String IdleTime = "IdleTime";
+
+
+ public static final String Payload = "Payload";
+ public static final int XMIPayload = 1000;
+ public static final int CASRefID = 1001;
+ public static final int Metadata = 1002;
+ public static final int Exception= 1003;
+ public static final int XCASPayload = 1004;
+ public static final int None = 1005;
+
+
+
+
+ public static final String Command = "Command";
+ public static final int Process = 2000;
+ public static final int GetMeta = 2001;
+ public static final int CollectionProcessComplete = 2002;
+ public static final int Terminate = 2003;
+ public static final int ACK = 2004;
+ public static final int ReleaseCAS = 2005;
+ public static final int Stop = 2006;
+
+
+ public static final String MessageType = "MessageType";
+ public static final int Request = 3000;
+ public static final int Response = 3001;
+
+
+ static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/MessageContext.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/MessageContext.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/MessageContext.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/MessageContext.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,26 @@
+package org.apache.uima.aae.message;
+
+
+import org.apache.uima.aae.controller.Endpoint;
+import org.apache.uima.aae.error.AsynchAEException;
+import org.apache.uima.aae.error.ErrorContext;
+
+public interface MessageContext
+{
+ public String getMessageStringProperty( String aMessagePropertyName ) throws AsynchAEException;
+ public int getMessageIntProperty( String aMessagePropertyName ) throws AsynchAEException;
+ public long getMessageLongProperty( String aMessagePropertyName ) throws AsynchAEException;
+ public Object getMessageObjectProperty( String aMessagePropertyName ) throws AsynchAEException;
+ public Endpoint getEndpoint();
+
+ public String getStringMessage() throws AsynchAEException;
+ public Object getObjectMessage() throws AsynchAEException;
+ public byte[] getByteMessage() throws AsynchAEException;
+ public Object getRawMessage();
+ public boolean propertyExists(String aKey) throws AsynchAEException;
+ public void setMessageArrivalTime( long anArrivalTime );
+ public long getMessageArrivalTime();
+ public String getEndpointName();
+
+ static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/UIMAMessage.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/UIMAMessage.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/UIMAMessage.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/UIMAMessage.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,11 @@
+package org.apache.uima.aae.message;
+
+public class UIMAMessage
+{
+ public static final String ServerURI = "ServerURI";
+ public static final String EndpointName ="EndpointName";
+ public static final String RawMsg ="RawMsg";
+
+
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/UimaEEShutdownTriggerEvent.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/UimaEEShutdownTriggerEvent.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/UimaEEShutdownTriggerEvent.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/message/UimaEEShutdownTriggerEvent.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,32 @@
+/**
+ *
+ */
+package org.apache.uima.aae.message;
+
+import org.apache.uima.aae.controller.AnalysisEngineController;
+import org.springframework.context.ApplicationEvent;
+
+/**
+ *
+ */
+public class UimaEEShutdownTriggerEvent extends ApplicationEvent
+{
+ private AnalysisEngineController targetController = null;
+ /**
+ * @param source
+ */
+ public UimaEEShutdownTriggerEvent(Object source)
+ {
+ super(source);
+ }
+ public AnalysisEngineController getTargetController()
+ {
+ return targetController;
+ }
+ public void setTargetController(AnalysisEngineController targetController)
+ {
+ this.targetController = targetController;
+ }
+
+
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/BaseMonitor.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/BaseMonitor.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/BaseMonitor.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/BaseMonitor.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,102 @@
+package org.apache.uima.aae.monitor;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.management.MBeanServerConnection;
+import javax.management.MBeanServerFactory;
+import javax.management.remote.JMXConnector;
+import javax.management.remote.JMXConnectorFactory;
+import javax.management.remote.JMXServiceURL;
+
+import org.apache.uima.aae.controller.Endpoint;
+import org.apache.uima.aae.monitor.statistics.LongNumericStatistic;
+import org.apache.uima.aae.monitor.statistics.Statistic;
+import org.apache.uima.aae.monitor.statistics.Statistics;
+import org.springframework.jmx.support.MBeanServerConnectionFactoryBean;
+
+import com.sun.jmx.remote.security.MBeanServerAccessController;
+
+public class BaseMonitor implements Monitor
+{
+ private Map monitorMap = new HashMap();
+ private MBeanServerConnection server;
+ private Map thresholds = null;
+
+
+ public BaseMonitor( String jmxServerURI ) throws Exception
+ {
+ JMXServiceURL url = new JMXServiceURL (jmxServerURI) ;
+ JMXConnector connector = JMXConnectorFactory.connect(url);
+ server =connector.getMBeanServerConnection();
+
+ }
+
+ public void setThresholds( Map aThresholdMap)
+ {
+ thresholds = aThresholdMap;
+ }
+ public Map getThresholds()
+ {
+ return thresholds;
+ }
+
+ public void addStatistic(String aName, Statistic aStatistic, Endpoint anEndpoint)
+ {
+
+// if ( aStatistic.isJMXEnabled())
+// {
+// //server.
+// }
+
+ }
+
+ public Statistic getStatistic(String key)
+ {
+ // TODO Auto-generated method stub
+ return null;
+ }
+ public void addStatistic(String key, Statistic aStatistic)
+ {
+ // TODO Auto-generated method stub
+
+ }
+ public LongNumericStatistic getLongNumericStatistic(String aComponent, String aStatisticName)
+ {
+ // TODO Auto-generated method stub
+ return null;
+ }
+ public Statistic getStatistic(String aComponentName, String aStatisticName)
+ {
+ // TODO Auto-generated method stub
+ return null;
+ }
+ public Statistics getStatistics(String aComponentName)
+ {
+ // TODO Auto-generated method stub
+ return null;
+ }
+ public void incrementCount(String aComponent, String aStatisticName)
+ {
+ // TODO Auto-generated method stub
+
+ }
+ public void resetCountingStatistic(String aComponent, String aStatisticName)
+ {
+ // TODO Auto-generated method stub
+
+ }
+ public long componentMapSize()
+ {
+ return 0;
+ }
+
+ public long thresholdMapSize()
+ {
+ return 0;
+ }
+
+
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/Monitor.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/Monitor.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/Monitor.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/Monitor.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,43 @@
+package org.apache.uima.aae.monitor;
+
+import java.util.Map;
+
+import org.apache.uima.aae.monitor.statistics.LongNumericStatistic;
+import org.apache.uima.aae.monitor.statistics.Statistic;
+import org.apache.uima.aae.monitor.statistics.Statistics;
+
+public interface Monitor
+{
+ public static final String MetadataRequestTimeoutCount = "MetadataRequestTimeoutCount";
+ public static final String ProcessRequestTimeoutCount = "ProcessRequestTimeoutCount";
+ public static final String ErrorCount = "ErrorCount";
+ public static final String ProcessErrorCount = "ProcessErrorCount";
+ public static final String TotalProcessErrorCount = "TotalProcessErrorCount";
+ public static final String ProcessErrorRetryCount = "ProcessErrorRetryCount";
+ public static final String GetMetaErrorCount = "GetMetaErrorCount";
+ public static final String GetMetaErrorRetryCount = "GetMetaErrorRetryCount";
+ public static final String CpCErrorCount = "CpcErrorCount";
+ public static final String ProcessCount = "ProcessCount";
+ public static final String IdleTime = "IdleTime";
+ public static final String TotalDeserializeTime = "TotalDeserializeTime";
+ public static final String TotalSerializeTime = "TotalSerializeTime";
+ public static final String TotalAEProcessTime = "TotalAEProcessTime";
+
+ public void addStatistic( String key, Statistic aStatistic);
+// public Statistic getStatistic( String key );
+
+ public Statistic getStatistic( String aComponentName, String aStatisticName );
+ public Statistics getStatistics( String aComponentName );
+
+ public LongNumericStatistic getLongNumericStatistic( String aComponent, String aStatisticName );
+ public void resetCountingStatistic( String aComponent, String aStatisticName );
+ public void incrementCount(String aComponent, String aStatisticName );
+
+ public void setThresholds( Map aThresholdMap);
+ public Map getThresholds();
+ public long componentMapSize();
+ public long thresholdMapSize();
+
+
+ static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/MonitorBaseImpl.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/MonitorBaseImpl.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/MonitorBaseImpl.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/MonitorBaseImpl.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,144 @@
+package org.apache.uima.aae.monitor;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.uima.aae.monitor.statistics.LongNumericStatistic;
+import org.apache.uima.aae.monitor.statistics.Statistic;
+import org.apache.uima.aae.monitor.statistics.Statistics;
+
+public class MonitorBaseImpl implements Monitor
+{
+ private Map componentStatistics = new HashMap();
+ private Map thresholds = null;
+
+ public void setThresholds( Map aThresholdMap)
+ {
+ thresholds = aThresholdMap;
+ }
+ public Map getThresholds()
+ {
+ return thresholds;
+ }
+
+ public void addStatistic(String aComponentName, Statistic aStatistic)
+ {
+ if ( componentStatistics.containsKey(aComponentName))
+ {
+ Statistics stats = getStatistics(aComponentName);
+ if ( !stats.containsKey(aStatistic.getName()) )
+ {
+ stats.put(aStatistic.getName(), aStatistic);
+ }
+ }
+ else
+ {
+ Statistics stats = new Statistics();
+ stats.put( aStatistic.getName(), aStatistic);
+ componentStatistics.put( aComponentName, stats );
+ }
+ }
+ public LongNumericStatistic getLongNumericStatistic(String aComponent, String aStatisticName)
+ {
+ LongNumericStatistic countStat =
+ (LongNumericStatistic) this.getStatistic(aComponent, aStatisticName);
+ if ( countStat == null )
+ {
+ countStat = new LongNumericStatistic(aStatisticName);
+ addStatistic(aComponent, countStat);
+
+ }
+// return (LongNumericStatistic) this.getStatistic(aComponent, aStatisticName);
+ return countStat;
+ }
+
+ public synchronized void incrementCount(String aComponent, String aStatisticName)
+ {
+ LongNumericStatistic countStat = getLongNumericStatistic(aComponent, aStatisticName);
+ if ( countStat == null )
+ {
+ countStat = new LongNumericStatistic(aStatisticName);
+ addStatistic(aComponent, countStat);
+ }
+ countStat.increment();
+
+ }
+
+ public Statistics getStatistics( String aComponentName )
+ {
+ return (Statistics)componentStatistics.get( aComponentName );
+ }
+
+ public synchronized void resetCountingStatistic(String aComponent,String aStatisticName)
+ {
+ LongNumericStatistic countStat = getLongNumericStatistic(aComponent, aStatisticName);
+ if ( countStat != null )
+ {
+ synchronized( countStat)
+ {
+// System.out.println("Resetting Statistic:"+aStatisticName+" For Component:"+aComponent);
+ countStat.reset();
+ }
+ }
+ }
+
+ public Statistic getStatistic(String aComponentName, String aStatisticName)
+ {
+
+ if ( componentStatistics.containsKey(aComponentName))
+ {
+ Statistics stats = getStatistics(aComponentName);
+ if ( stats.containsKey(aStatisticName ))
+ {
+ return (Statistic)stats.get(aStatisticName );
+ }
+ }
+ else
+ {
+ LongNumericStatistic countStat = new LongNumericStatistic(aStatisticName);
+ addStatistic(aComponentName, countStat);
+ return (Statistic)countStat;
+ }
+
+ return null;
+ }
+
+
+
+/*
+ public void addStatistic(String key, Statistic aStatistic)
+ {
+ if ( !monitorMap.containsKey(key))
+ {
+ monitorMap.put(key, aStatistic);
+ }
+ }
+
+ public Statistic getStatistic(String key)
+ {
+ if ( monitorMap.containsKey(key))
+ {
+ return (Statistic)monitorMap.get(key);
+ }
+ return null;
+ }
+*/
+ public long componentMapSize()
+ {
+ if ( componentStatistics != null )
+ {
+ return (long)componentStatistics.size();
+ }
+ return 0;
+ }
+ public long thresholdMapSize()
+ {
+ if ( thresholds != null )
+ {
+ return thresholds.size();
+ }
+ return 0;
+
+ }
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/BaseStatistic.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/BaseStatistic.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/BaseStatistic.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/BaseStatistic.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,17 @@
+package org.apache.uima.aae.monitor.statistics;
+
+public abstract class BaseStatistic //implements Statistic
+{
+ private String name;
+
+ public BaseStatistic( String aName )
+ {
+ name = aName;
+ }
+ public String getName()
+ {
+ return name;
+ }
+
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/ComponentStatistics.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/ComponentStatistics.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/ComponentStatistics.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/ComponentStatistics.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,65 @@
+package org.apache.uima.aae.monitor.statistics;
+
+import org.apache.uima.aae.monitor.Monitor;
+
+public class ComponentStatistics implements ComponentStatisticsMBean
+{
+ /**
+ *
+ */
+ private static final long serialVersionUID = 1L;
+ private Statistics statistics;
+
+ public ComponentStatistics()
+ {
+ }
+
+ public ComponentStatistics( Statistics aStatistics )
+ {
+ statistics = aStatistics;
+ }
+ private Statistic getStatistic( String aName)
+ {
+ if ( statistics == null )
+ {
+ return null;
+ }
+ return (Statistic)statistics.get(aName);
+
+
+ }
+ public long getNumberOfCASesProcessed()
+ {
+ Statistic statistic = getStatistic(Monitor.ProcessCount);
+ if (statistic != null && statistic instanceof LongNumericStatistic)
+ {
+ return ((LongNumericStatistic)statistic).getValue();
+ }
+ return 0;
+ }
+
+ public long getNumberOfProcessErrors()
+ {
+ Statistic statistic = getStatistic(Monitor.TotalProcessErrorCount);
+ if (statistic != null && statistic instanceof LongNumericStatistic)
+ {
+ return ((LongNumericStatistic)statistic).getValue();
+ }
+ return 0;
+ }
+
+ public void reset()
+ {
+ reset( getStatistic(Monitor.ProcessCount) );
+ reset( getStatistic(Monitor.TotalProcessErrorCount) );
+ }
+
+ private void reset( Statistic aStatistic )
+ {
+ if (aStatistic != null && aStatistic instanceof LongNumericStatistic)
+ {
+ ((LongNumericStatistic)aStatistic).reset();
+ }
+
+ }
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/ComponentStatisticsMBean.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/ComponentStatisticsMBean.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/ComponentStatisticsMBean.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/ComponentStatisticsMBean.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,12 @@
+package org.apache.uima.aae.monitor.statistics;
+
+import java.io.Serializable;
+
+public interface ComponentStatisticsMBean extends Serializable
+{
+ public void reset();
+
+ public long getNumberOfCASesProcessed();
+
+ public long getNumberOfProcessErrors();
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/DelegateStats.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/DelegateStats.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/DelegateStats.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/DelegateStats.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,12 @@
+package org.apache.uima.aae.monitor.statistics;
+
+import java.io.Serializable;
+import java.util.HashMap;
+
+public class DelegateStats extends HashMap implements Serializable
+{
+ static final long serialVersionUID = -1L;
+
+
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/IntNumericStatistic.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/IntNumericStatistic.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/IntNumericStatistic.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/IntNumericStatistic.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,38 @@
+package org.apache.uima.aae.monitor.statistics;
+
+public class IntNumericStatistic extends BaseStatistic
+implements NumericStatistic
+{
+ private int value;
+
+ public IntNumericStatistic( String aName)
+ {
+ super( aName);
+ }
+
+ public IntNumericStatistic( String aName, int anInitialValue)
+ {
+ super( aName);
+ value = anInitialValue;
+ }
+ public void decrement()
+ {
+ if ( value > 0 )
+ {
+ value--;
+ }
+ }
+
+ public void increment()
+ {
+ value++;
+ }
+
+ public void reset()
+ {
+ value = 0;
+ }
+
+
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/LongNumericStatistic.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/LongNumericStatistic.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/LongNumericStatistic.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/LongNumericStatistic.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,43 @@
+package org.apache.uima.aae.monitor.statistics;
+
+public class LongNumericStatistic extends NumericStatisticBaseImpl
+implements LongNumericStatisticMBean
+//implements NumericStatisticBean
+{
+ private long value=0;
+
+ public LongNumericStatistic( String aName)
+ {
+ super( aName);
+ }
+
+ public void decrement()
+ {
+ if ( value > 0 )
+ {
+ value--;
+ }
+ }
+
+ public void increment()
+ {
+ value++;
+ }
+
+ public void increment(long anIncrementBy)
+ {
+ value += anIncrementBy;
+ }
+
+ public void reset()
+ {
+ value = 0;
+ }
+
+ public long getValue()
+ {
+ return value;
+ }
+
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/LongNumericStatisticMBean.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/LongNumericStatisticMBean.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/LongNumericStatisticMBean.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/LongNumericStatisticMBean.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,13 @@
+package org.apache.uima.aae.monitor.statistics;
+
+import java.io.Serializable;
+
+public interface LongNumericStatisticMBean extends Serializable
+{
+ public long getValue();
+
+ public String getName();
+
+ public void reset();
+
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/NumericStatistic.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/NumericStatistic.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/NumericStatistic.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/NumericStatistic.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,9 @@
+package org.apache.uima.aae.monitor.statistics;
+
+public interface NumericStatistic extends Statistic
+{
+ public void increment();
+ public void decrement();
+
+public static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/NumericStatisticBaseImpl.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/NumericStatisticBaseImpl.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/NumericStatisticBaseImpl.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/NumericStatisticBaseImpl.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,18 @@
+package org.apache.uima.aae.monitor.statistics;
+
+public abstract class NumericStatisticBaseImpl
+extends BaseStatistic implements NumericStatistic
+{
+ public NumericStatisticBaseImpl(String aName )
+ {
+ super(aName);
+ }
+
+ public abstract void increment();
+
+ public abstract void reset();
+
+ public abstract void decrement();
+
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/NumericStatisticBean.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/NumericStatisticBean.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/NumericStatisticBean.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/NumericStatisticBean.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,10 @@
+package org.apache.uima.aae.monitor.statistics;
+
+
+public interface NumericStatisticBean// extends UIMAStatistic
+{
+ public void increment();
+ public void decrement();
+
+public static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/SimpleSwitch.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/SimpleSwitch.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/SimpleSwitch.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/SimpleSwitch.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,23 @@
+package org.apache.uima.aae.monitor.statistics;
+
+public class SimpleSwitch implements SimpleSwitchMBean
+{
+ private int state;
+
+ public SimpleSwitch() { state = 0;}
+
+// public SimpleSwitch(int aState) { state = aState;}
+
+ public void flip()
+ {
+ state = (state ==0) ? 1 : 0;
+ }
+
+ public int getState()
+ {
+ return state;
+ }
+
+
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/SimpleSwitchMBean.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/SimpleSwitchMBean.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/SimpleSwitchMBean.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/SimpleSwitchMBean.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,9 @@
+package org.apache.uima.aae.monitor.statistics;
+
+public interface SimpleSwitchMBean
+{
+ public void flip();
+ public int getState();
+
+public static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/Statistic.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/Statistic.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/Statistic.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/Statistic.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,12 @@
+package org.apache.uima.aae.monitor.statistics;
+
+public interface Statistic
+{
+// public void add( Object key, Object value);
+// public Object get(Object key);
+// public void increment(Object key);
+ public void reset();
+ public String getName();
+
+public static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/StatisticBase.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/StatisticBase.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/StatisticBase.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/StatisticBase.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,49 @@
+package org.apache.uima.aae.monitor.statistics;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class StatisticBase implements Statistic
+{
+ private Map statMap = new HashMap();
+
+ public void add(Object key, Object value)
+ {
+ statMap.put( key, value);
+ }
+
+ public void reset()
+ {
+
+ }
+
+ public Object get(Object key)
+ {
+ if ( statMap.containsKey(key))
+ {
+ return statMap.get(key);
+ }
+ return null;
+ }
+
+ public synchronized void increment(Object key)
+ {
+ if ( statMap.containsKey(key) )
+ {
+ Long count = (Long)statMap.get(key);
+ count++;
+ statMap.remove(key);
+ add(key, count);
+ }
+
+ }
+
+ public String getName()
+ {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/Statistics.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/Statistics.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/Statistics.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/Statistics.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,10 @@
+package org.apache.uima.aae.monitor.statistics;
+
+import java.util.HashMap;
+
+public class Statistics extends HashMap
+{
+
+
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/StringStatistic.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/StringStatistic.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/StringStatistic.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/StringStatistic.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,9 @@
+package org.apache.uima.aae.monitor.statistics;
+
+public interface StringStatistic extends UIMAStatistic
+{
+ public void setValue( String aValue);
+ public String getValue();
+
+public static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/StringStatisticImpl.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/StringStatisticImpl.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/StringStatisticImpl.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/StringStatisticImpl.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,28 @@
+package org.apache.uima.aae.monitor.statistics;
+
+public class StringStatisticImpl extends BaseStatistic implements StringStatistic
+{
+ private String value;
+
+ public StringStatisticImpl( String aName, String anInitialValue)
+ {
+ super(aName);
+ value = anInitialValue;
+ }
+ public String getValue()
+ {
+ return value;
+ }
+
+ public void setValue( String aValue)
+ {
+ value = aValue;
+ }
+ public void reset()
+ {
+ value = "";
+ }
+
+
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/TimerStats.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/TimerStats.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/TimerStats.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/TimerStats.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,11 @@
+package org.apache.uima.aae.monitor.statistics;
+
+import java.util.HashMap;
+
+public class TimerStats extends HashMap<String,Long>
+{
+ static final long serialVersionUID = -1L;
+
+
+private static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/UIMAStatistic.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/UIMAStatistic.java?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/UIMAStatistic.java (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/java/org/apache/uima/aae/monitor/statistics/UIMAStatistic.java Tue Jan 8 06:38:38 2008
@@ -0,0 +1,9 @@
+package org.apache.uima.aae.monitor.statistics;
+
+public interface UIMAStatistic
+{
+ public void reset();
+ public String getName();
+
+public static final String copyright = com.ibm.uima.copyright.Copyright.COPYRIGHT;
+}
Added: incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/resources/uimaee_messages.properties
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/resources/uimaee_messages.properties?rev=610003&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/resources/uimaee_messages.properties (added)
+++ incubator/uima/sandbox/trunk/uima-ee/uimaj-ee-core/src/main/resources/uimaee_messages.properties Tue Jan 8 06:38:38 2008
@@ -0,0 +1,124 @@
+
+UIMAEE_service_id_INFO = Starting Uima EE Service On {0}
+UIMAEE_exception__WARNING = {0}
+UIMAEE_invalid_cpc_request__INFO = Invalid {0} Request. Analysis Engine Instance Not Found For Thread:
+UIMAEE_primary_cas_pool_init__CONFIG = Primary CAS Pool Size: {0} Context: {1}. Supports Incoming Service Requests.
+UIMAEE_secondary_cas_pool_init__CONFIG = Secondary CAS Pool Size: {0} Context: {1}. Supports Incoming Replies from Delegates.
+UIMAEE_retrieve_flow_object__FINEST = Retrieving Flow Object For CAS with Reference Id: {0}
+UIMAEE_new_flow_object__FINEST = Computing New Flow Object For CAS with Reference Id: {0}
+UIMAEE_next_step__FINEST = Executing Next Step For CAS with Reference Id: {0}. Sending Process Request To Delegate: {1}
+UIMAEE_final_step__FINEST = Completed Processing CAS with Reference Id: {0}. Time Spent in Anotator: {1}
+UIMAEE_final_step_show_internal_stats__FINEST = Controller: {0} Final Step::FlowMap Size:{1} InProcessCache Size:{2} OriginMap Size:{3} StatsMap Size:{4}
+UIMAEE_merge_ts_from_delegate__CONFIG = Merging Typesystem From Delegate: {0}
+UIMAEE_all_ts_merged__CONFIG = All Typesystems Have Been Merged
+UIMAEE_initialized_controller__INFO = ********* Initialized the Controller. {0} Ready To Process. ********
+UIMAEE_cas_timeout_no_reply__INFO = Timeout While Waiting For Reply From Delegate:{0} Process CAS Request Timed Out. Configured Reply Window Of {1}. Cas Reference Id:{2}
+UIMAEE_meta_timeout_no_reply__INFO = Timeout While Waiting For Reply From Delegate:{0} GetMeta Request Timed Out. Configured Reply Window Of {1}.
+UIMAEE_cpc_timeout_no_reply__INFO = Timeout While Waiting For Reply From Delegate{0} Collection Process Complete Request Timed Out. Configured Reply Window Of {1}.
+UIMAEE_starting_worker__FINEST = Starting Analysis Engine Worker Thread.
+UIMAEE_got_work__FINEST = Thread: {0} Received CAS To Analyze. CAS Reference Id: {1} Cas Hash Code: {2}
+UIMAEE_completed_analysis__FINEST = Worker Thread: {0} Controller: {1} Completed Analysis of a CAS. CAS Reference Id: {2}. Time Spent in Analysis: {3} ms.
+UIMAEE_handling_metadata_request__FINEST = Handling Request For Metadata Message from: {0}
+UIMAEE_msg_for_next_handler__FINEST = Dispatching Message: {0} to the Next Handler in the Chain
+UIMAEE_expired_message__INFO = Received Reply Message for Request that Has Already Expired From Delegate: {0} CAS Reference Id: {1}
+UIMAEE_no_reply_destination__INFO = Attempt to Send Reply Failed. Destination For Reply is Unknown. Cas Reference Id: {0}
+UIMAEE_handling_bad_destination__INFO = Handling Unknown Destination. Destination: {0} Cas Reference Id: {1}
+UIMAEE_message_has_no_cargo__INFO = Request Message Contains No XMI Data. Message Received From: {0}
+UIMAEE_message_has_cas_refid__INFO = CAS Reference Id not in the Message from Delegate: {0}
+UIMAEE_no_descriptors_in_map_CONFIG = Unable to initialize CasManager. Analysis Engine Descriptors not provided
+UIMAEE_process_exception__INFO = Process Request Failed. Delegate Analysis Engine: {0} Cas Reference Id: {1} Reason: {2}
+UIMAEE_app_cpc_request_FINEST = Application Initiated Collection Processing Complete Request
+UIMAEE_cpc_request_not_done_INFO = Asynchronous Client Has Stopped. Collection Processing Complete Request Was Not Handled.
+UIMAEE_started_cpc_request_timer_FINEST = Collection Processing Complete Request Has Been Sent. Timer Started.
+UIMAEE_cancelled_cpc_request_timer_FINEST = Collection Processing Complete Request Timer Has Been Cancelled.
+UIMAEE_cas_manager_wrapper_notdefined__CONFIG = CasManager Wrapper Not Avaialable
+UIMAEE_terminating_service__INFO = Service {0} is Shutting Down
+UIMAEE_primitive_ctrl_init_info__CONFIG - Initializing Async Primitive Service. Number of Worker Threads: {0}
+UIMAEE_terminating_thread__INFO = Terminatig Worker Thread in Async Primitive Service: {0}
+UIMAEE_worker_threads_done__INFO = All Worker Threads Terminated in Async Primitive Service: {0}
+UIMAEE_killing_process__SEVERE = Service {0} Killed With System.exit(0)
+UIMAEE_rceived_work__FINE = Worker Thread: {0} Received Work. Cas ReferenceId: {1}
+UIMAEE_cas_notin_cache__WARNING = Worker Thread: {0} Cas ReferenceId: {1} Not In Cache.
+UIMAEE_produced_new_cas__FINE = Worker Thread: {0} Controller: {1} Produced New Cas: {2} From Input Cas: {3}
+UIMAEE_worker_thread_terminated__INFO = Worker Thread: {0} Terminated
+UIMAEE_request_cas__FINE = Requesting CAS from CasPool For CAS Deserialization. Cas Sent From: {0}
+UIMAEE_request_cas_granted__FINE = Obtained CAS from CasPool For CAS Deserialization. Cas Sent From: {0}
+UIMAEE_deserialized_cas_ready_to_process_FINE = Deserialized CAS from XMI. CAS Sent From: {0}
+UIMAEE_got_cas__FINEST = Got Cas From: {0} Cas Received Contains: {1}
+UIMAEE_duplicate_request__INFO = Duplicate Request With Cas Reference Id: {0} Received. Ignoring Duplicate.
+UIMAEE_no_endpoint_for_reply__INFO = Rely-To Destination Not Found For Cas Reference Id: {0}
+UIMAEE_new_cas__FINE = New Cas: {0} Was Produced By: {1}
+UIMAEE_analyzing_cas__FINE = Analyzing Cas: {0}
+UIMAEE_dispatch_msg_to_handler__FINE = Dispatching Message: {0} From: {1} To Handler: {2}
+UIMAEE_no_handler_for_message__FINE = Handler For Message: {0} From: {1} Not Found
+UIMAEE_show_roundtrip_time__FINE = Cas: {0} Round Trip To and From: {1} Took: {2} ms
+UIMAEE_show_time_spent_in_delegate__FINE = Cas: {0} Spent: {1} ms In Delegate: {2}
+UIMAEE_show_time_spent_in_comms__FINE = Cas: {0} Spent: {1} ms In Comms. Delegate: {2}
+\UIMAEE_cancel_timer__FINE = Cancelling Timer For Delegate: {0} Cas: {1}
+UIMAEE_endpoint_not_found__INFO = Endpoint Object Not Found For Delegate: {0} Cas: {1}
+UIMAEE_number_parallel_delegates_FINE = Number of Parallel Delegates: {0}
+UIMAEE_rcvd_reply_FINEST = Received Reply From: {0} Cas: {1} XMI: {2}
+UIMAEE_delegate_responded_count_FINEST = Number Of Delegates Responded So Far: {0} Cas: {1}
+UIMAEE_high_water_mark_FINEST = Deserializing Cas Using High Water Mark: {0} Cas: {1}
+UIMAEE_total_delegate_count_FINEST = Deserializing XMI into CAS. Response From: {0} {1} of {2}
+UIMAEE_add_default_eh__CONFIG = Adding Default Error Handler For Controller: {0}
+UIMAEE_dropping_cas__FINE = Releasing Cas: {0} Controller: {1}
+UIMAEE_released_cas__FINE = Cas With Reference Id: {0} Released by Controller: {1} Cas Hash Code: {2}
+UIMAEE_unable_to_release_cas__WARNING = Unable to Release Cas: {0}. Cas is Null. Controller: {1}
+UIMAEE_removed_cache_entry__FINE = Removed Cache Entry For Cas Reference Id: {0} Controller: {1}
+UIMAEE_save_time__FINE = Saving Time: {0} Cas: {1} Controller: {2} Endpoint: {3} Key: {4}
+UIMAEE_get_time__FINE = Getting Time For Cas: {0} Controller: {1} Endpoint: {2} Key: {3}
+UIMAEE_time_not_found__FINE = Time Info Not Found For Cas: {0} Controller: {1} Endpoint: {2} Key: {3}
+UIMAEE_endpoint_to_key_map__FINE = Mapping Key: {0} To Endpoint: {1}
+UIMAEE_lookup_flow__FINE = Controller: {0} Looking Up Flow For Cas: {1}
+UIMAEE_lookup_flow_ok__FINE = Controller: {0} Computing Subordinate Flow Object For Cas {1} Produced By {2} From Input Cas: {3}
+UIMAEE_parallel_step__FINE = Controller: {0} Executine Parallel Step For Cas: {1}
+UIMAEE_analysis_results__FINEST = {0}
+UIMAEE_destroying_ae__INFO = {0} Calling Destroy On AE instance # {1}
+UIMAEE_invalid_endpoint__WARNING = Invalid reply. Unable to lookup endpoint: {0} Cas Reference Id: {1}
+UIMAEE_no_consumers__INFO = No UIMA EE Service Delegates To Process Cas Reference Id: {0} Endpoint: {1}
+UIMAEE_disabled_delegate_INFO = Aggregate Controller {0} Disabled Delegate Component: {1}
+UIMAEE_invalid_request__INFO = Stale {0} Request
+UIMAEE_recvd_cpc_reply__FINE = Received CPC Reply From Delegate: {0}
+UIMAEE_send_cpc_req__FINE = Sending CPC Request To Delegate: {0}
+UIMAEE_show_cache_size__FINEST = Current Size of the InProcess Cache: {0}
+UIMAEE_request_cas__FINEST = Requesting New Cas For Deserialization From Endpoint: {0}
+UIMAEE_handling_exception_from_delegate_FINE = Service: {0} Received Exception From Delegate: {1}
+UIMAEE_no_endpoint__INFO = Unable to Forward Exception Up To Parent From: {0}. Destination Unknown.
+UIMAEE_retrying_last_command__INFO = Aggregate Controller: {0} Retrying Last Command: {1} Cas Reference Id: {2}
+UIMAEE_no_retry__INFO = Aggregate Controller: {0} Will Not Retry the Last Command: {1} Cas Reference Id: {2}
+UIMAEE_cas_not_in_cache__INFO = Controller: {0} Unable to Fetch CAS instance from Cache for Cas Reference Id: {1} While Handling Reply From Endpoint: {2}
+UIMAEE_deserialize_error__WARNING = Controller: {0} Unable to De-serialize CAS with Input Cas Reference Id: {1} Received From: {2}
+UIMAEE_dump_cas__FINEST = Serialized CAS: {0}
+UIMAEE_metadata_recvd_from_invalid_delegate__INFO = Controller: {0} Received Metadata From an Invalid (Possibly Disabled) Delegate: {1}
+UIMAEE_getmeta_retry_exceeded__INFO = Controller: {0} Exceeded GetMeta Retry Threshold Of: {1} For Delegate: {2} Configured Action: {3}
+UIMAEE_no_endpoint_for_getmeta_retry__INFO = Controller: {0} Unable to Retry GetMeta. Delegate Endpoint Not Specified.
+UIMAEE_no_endpoint_provided__INFO = Controller: {0} Delegate Endpoint Not Specified While Handling 'Process' Exception
+UIMAEE_removing_endpoint_from_map__INFO = Controller: {0} Removing Delegate: {1} From The Delegate Map Due To Excessive Errors
+UIMAEE_no_threshold_for_endpoint__CONFIG = Controller: {0} Threshold For {1} Not Defined For Delegate: {2}
+UIMAEE_invalid_context_object__INFO = Controller: {0} Invalid Input Context Object. Expect Object of Type MessageContext Received: {1} Instead
+UIMAEE_retry_cas__FINE = Controller: {0} Retrying Process CAS Command. Delegate: {1} Cas Reference Id: {2}
+UIMAEE_cas_retries_exceeded__FINE = Controller: {0} Process CAS Retries Exceeded Or Not Configured. Delegate: {1} Cas Reference Id: {2}
+UIMAEE_process_cas_exceeded_threshold__INFO = Controller: {0} Process CAS Threshold Exceeded Configured Maximum.Delegate: {1} Cas Reference Id: {2} Threshold: {3} Action To Take: {4}
+UIMAEE_ignore_error__INFO = Controller: {0} Ignoring Error Of Class: {1}
+UIMAEE_show_cache_entry_key__FINEST = InProcessCache Contains: {0} Entries: {1}
+UIMAEE_remove_cache_entry_for_cas__FINEST = Removing Cache Entry For Cas Reference Id: {0}
+UIMAEE_cas_is_null_remove_from_cache_failed__FINEST = Unable to Remove Cache Entry. Cas Reference Id is Null
+UIMAEE_cas_is_invalid_remove_from_cache_failed__FINEST = Unable to Remove Cache Entry. Provided Cas Reference Id: {0} is not a valid key.
+UIMAEE_cpc__FINEST = Controller: {0} Received CPC Request.
+UIMAEE_cpc_all_cases_processed__FINEST = Controller: {0} Processing CPC Request. All CASes Have Been Processed
+UIMAEE_release_cas_req__FINE = Controller: {0} Handling Release CAS Request. Releasing CAS Reference Id: {1}
+UIMAEE_cas_pool_config_INFO = Controller: {0} Configured CAS Pool For Context: {1} CAS Pool Size: {2}
+UIMAEE_invalid_cp_size__CONFIG = Controller: {0} Invalid Cas Pool Size. Remote Cas Multiplier {1} Cas Pool Size Exceeds the Aggregate Shadow Cas Pool Size. Remote CP Size: {2} Local CP Size: {3}
+UIMAEE_deserialize_cas_time_FINE = Deserialized CAS in {0} msec
+UIMAEE_process_termiate_event__INFO = Controller: {0} Received Terminate Event
+UIMAEE_register_controller__FINE = Controller: {0} Registered Child Controller: {1}
+UIMAEE_terminate_service__INFO = Controller: {0} Terminating Due To Timeout. Service on Endpoint: {1} Didnt Reply to GetMeta Request
+UIMAEE_dump_primitive_stats__INFO = Controller: {0} Stats: \n\t Total Idle Time: {1} millis\n\t Total Number CASes Processed: {2} \n\t Total CAS Deserialization Time: {3} millis\n\t Total CAS Serialization Time: {4} millis \n\t Total Time Spent In Analysis: {5}
+UIMAEE_dump_aggregate_stats__INFO = Controller: {0} Stats: \n\t Total Idle Time: {1} millis\n\t Total Number CASes Processed: {2} \n\t Total CAS Deserialization Time: {3} millis\n\t Total CAS Serialization Time: {4} millis
+UIMAEE_delegate_already_disabled__INFO = Controller: {0} Previously Disabled This Delegate: {1}. If Configured, the Controller Will Continue With The CAS: {2}
+UIMAEE_cpc_completed__FINE = Controller: {0} Processing CPC Request Completed
+UIMAEE_remote_delegate_ready__CONFIG= Controller: {0} Received Metadata from Remote Service: {1}
+UIMAEE_stop__INFO = Stopping Controller: {0}
+UIMAEE_stop_delegate__INFO = Controller: {0} Sending STOP Request to {1}
+UIMAEE_remove_cache_entry_for_cas__FINE = Removed Entry From InProcess Cache - Key: {0}
\ No newline at end of file