svn commit: r1173806 - /uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java

[cwiklik]

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);