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 2017/07/13 23:33:05 UTC
svn commit: r1801897 -
/uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java
Author: cwiklik
Date: Thu Jul 13 23:33:05 2017
New Revision: 1801897
URL: http://svn.apache.org/viewvc?rev=1801897&view=rev
Log:
UIMA-5477 Modified to restart broker in testSyncClientRecoveryFromBrokerStop()
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=1801897&r1=1801896&r2=1801897&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 Thu Jul 13 23:33:05 2017
@@ -302,7 +302,7 @@ public class TestUimaASExtended extends
}
@Test
public void testClient() throws Exception {
- System.out.println("-------------- testClientRecoveryFromBrokerFailure -------------");
+ System.out.println("-------------- testClient -------------");
System.setProperty("BrokerURL", broker.getConnectorByName(DEFAULT_BROKER_URL_KEY).getUri().toString());
BaseUIMAAsynchronousEngine_impl uimaAsEngine1 = new BaseUIMAAsynchronousEngine_impl();
@@ -318,7 +318,7 @@ public class TestUimaASExtended extends
@Test
public void testClientWithPrimitives() throws Exception {
- System.out.println("-------------- testClientRecoveryFromBrokerFailure -------------");
+ System.out.println("-------------- testClientWithPrimitives -------------");
System.setProperty("BrokerURL", broker.getConnectorByName(DEFAULT_BROKER_URL_KEY).getUri().toString());
BaseUIMAAsynchronousEngine_impl uimaAsEngine1 = new BaseUIMAAsynchronousEngine_impl();
@@ -1584,6 +1584,8 @@ public class TestUimaASExtended extends
// Stop the broker
broker2.stop();
broker2.waitUntilStopped();
+ Timer timer = new Timer();
+ timer.schedule(new StartBrokerTask(broker2, this),10000);
}
CAS cas = uimaAsEngine.getCAS();
cas.setDocumentText("Some Text");
@@ -1597,7 +1599,7 @@ public class TestUimaASExtended extends
cas.release();
}
}
-
+
uimaAsEngine.stop();
// expecting 5 failures due to broker missing
if ( errorCount != 5 ) {