You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2009/06/24 21:16:03 UTC
svn commit: r788138 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/BaseTestSupport.java
Author: cwiklik
Date: Wed Jun 24 19:16:02 2009
New Revision: 788138
URL: http://svn.apache.org/viewvc?rev=788138&view=rev
Log:
UIMA-1358
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/BaseTestSupport.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/BaseTestSupport.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/BaseTestSupport.java?rev=788138&r1=788137&r2=788138&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/BaseTestSupport.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/BaseTestSupport.java Wed Jun 24 19:16:02 2009
@@ -464,7 +464,6 @@
}
}
-
if (unexpectedException)
{
fail("Unexpected exception returned");
@@ -612,7 +611,9 @@
protected class UimaAsTestCallbackListener extends UimaAsBaseCallbackListener {
+ private String casSent = null;
public void onBeforeMessageSend(UimaASProcessStatus status) {
+ casSent = status.getCasReferenceId();
System.out.println("runTest: Received onBeforeMessageSend() Notification With CAS:"+status.getCasReferenceId());
}
@@ -642,9 +643,11 @@
if (casReferenceId == null) {
System.out.println("runTest: Received Reply Containing "+list.size()+" Exception(s)");
} else if ( parentCasReferenceId == null ) {
- System.out.println("runTest: Received Reply from CAS "+casReferenceId+" Containing "+list.size()+" Exception(s)");
+ if ( casSent.equals(casReferenceId)) {
+ receivedExpectedParentReferenceId = true;
+ }
+ System.out.println("runTest: Received Reply from CAS "+casReferenceId+" Containing "+list.size()+" Exception(s)");
} else {
- receivedExpectedParentReferenceId = true;
System.out.println("runTest: Received Reply from CAS "+casReferenceId+" (Parent "+parentCasReferenceId
+") Containing "+list.size()+" Exception(s)");
}
@@ -750,6 +753,16 @@
}
incrementCASesProcessed();
+ } else if ( aCAS != null ) {
+ if ( parentCasReferenceId != null )
+ {
+ System.out.println("runTest: Received Reply Containing CAS:"+casReferenceId+" The Cas Was Generated From Parent Cas Id:"+parentCasReferenceId);
+ }
+ else
+ {
+ System.out.println("runTest: Received Reply Containing CAS:"+casReferenceId);
+ }
+ incrementCASesProcessed();
}
}
private boolean isProcessTimeout( Exception e) {