Author: cwiklik Date: Tue Jun 21 14:40:26 2011 New Revision: 1138023 URL: http://svn.apache.org/viewvc?rev=1138023&view=rev Log: UIMA-2157 Added onBeforeProcessCAS()
Modified: uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/examples/as/RunRemoteAsyncAE.java Modified: uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/examples/as/RunRemoteAsyncAE.java URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/examples/as/RunRemoteAsyncAE.java?rev=1138023&r1=1138022&r2=1138023&view=diff ============================================================================== --- uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/examples/as/RunRemoteAsyncAE.java (original) +++ uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/examples/as/RunRemoteAsyncAE.java Tue Jun 21 14:40:26 2011 @@ -487,6 +487,15 @@ public class RunRemoteAsyncAE { long current = System.nanoTime() / 1000000 - mStartTime; casMap.put(status.getCasReferenceId(), current); } + /** + * This method is called when a CAS is picked up by remote UIMA AS + * from a queue right before processing. This callback identifies + * on which machine the CAS is being processed and by which UIMA AS + * service (PID). + */ + public void onBeforeProcessCAS(UimaASProcessStatus status, String nodeIP, String pid) { + + } }