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 2011/09/21 21:36:36 UTC
svn commit: r1173806 -
/uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java
Author: cwiklik
Date: Wed Sep 21 19:36:35 2011
New Revision: 1173806
URL: http://svn.apache.org/viewvc?rev=1173806&view=rev
Log:
UIMA-2229 Fix testCallbackListenerOnFailure to register callback listener before calling initialize
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java
Modified: uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java?rev=1173806&r1=1173805&r2=1173806&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java (original)
+++ uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java Wed Sep 21 19:36:35 2011
@@ -293,8 +293,9 @@ public class TestUimaASExtended extends
deployService(uimaAsEngine, relativePath + "/Deploy_NoOpAnnotatorWithPlaceholder.xml");
Map<String, Object> appCtx =
buildContext(broker2.getConnectorByName(DEFAULT_BROKER_URL_KEY_2).getUri().toString(), "NoOpAnnotatorQueue");
+ appCtx.put(UimaAsynchronousEngine.GetMetaTimeout, 1100);
appCtx.put(UimaAsynchronousEngine.Timeout, 1100);
- appCtx.put(UimaAsynchronousEngine.CpcTimeout, 1100);
+ appCtx.put(UimaAsynchronousEngine.CpcTimeout, 300);
initialize(uimaAsEngine, appCtx);
waitUntilInitialized();
int errorCount = 0;
@@ -314,7 +315,7 @@ public class TestUimaASExtended extends
uimaAsEngine.sendAndReceiveCAS(cas);
} catch( Exception e) {
errorCount++;
- System.out.println("Client Received Expected Error on CAS:"+(i+1));
+ System.out.println("Client Received Expected Error on CAS:"+(i+1)+" ErrorCount:"+errorCount);
} finally {
cas.release();
}
@@ -346,6 +347,7 @@ public class TestUimaASExtended extends
buildContext(broker2.getConnectorByName(DEFAULT_BROKER_URL_KEY_2).getUri().toString(), "NoOpAnnotatorQueue");
appCtx.put(UimaAsynchronousEngine.Timeout, 1100);
appCtx.put(UimaAsynchronousEngine.CpcTimeout, 1100);
+ appCtx.put(UimaAsynchronousEngine.GetMetaTimeout, 20000);
initialize(uimaAsEngine, appCtx);
waitUntilInitialized();
int errorCount=0;
@@ -2503,14 +2505,14 @@ public class TestUimaASExtended extends
Map<String, Object> appCtx = buildContext(String.valueOf(broker.getMasterConnectorURI()),
"NoOpAnnotatorQueue");
- initialize(eeUimaEngine, appCtx);
- // Wait until the top level service returns its metadata
- waitUntilInitialized();
- CAS cas = eeUimaEngine.getCAS();
// Register special callback listener. This listener will receive
// an exception with the Cas Reference id.
TestListener listener = new TestListener(this);
eeUimaEngine.addStatusCallbackListener(listener);
+ initialize(eeUimaEngine, appCtx);
+ // Wait until the top level service returns its metadata
+ waitUntilInitialized();
+ CAS cas = eeUimaEngine.getCAS();
// Send request out and save Cas Reference id
String casReferenceId = eeUimaEngine.sendCAS(cas);