Preparation for enabling travis ci ... (#156)

* prepare for enabling travis ci and fix an issue that cause test to hang if fork join pool only has single thread

* add new line in travis file

Author: meiliang86

.travis.yml

@@ -0,0 +1,15 @@
+language: java
+
+sudo: required
+
+env:
+  - SKIP_DOCKER_SERVICE=true # used to skip docker service tests in WorkflowTest for now.
+
+before_install:
+  - pushd /tmp
+  - wget http://www-us.apache.org/dist/thrift/0.9.3/thrift-0.9.3.tar.gz
+  - tar xfz thrift-0.9.3.tar.gz
+  - cd thrift-0.9.3
+  - ./configure --enable-libs=no --enable-tests=no --enable-tutorial=no --with-cpp=no --with-c_glib=no --with-java=yes --with-ruby=no --with-erlang=no --with-go=no --with-nodejs=no
+  - make -j2 && sudo make install
+  - popd

build.gradle

@@ -60,11 +60,6 @@ compileJava {
             ".*/generated-sources/.*" << "-Werror"
 }
 
-license {
-    header = project.file('license-header.txt')
-    exclude '**/com/uber/cadence/*.java'
-}
-
 compileTestJava {
     options.encoding = 'UTF-8'
     options.compilerArgs << "-Xlint:unchecked" << "-Xlint:deprecation" << "-XepExcludedPaths:" +
@@ -99,3 +94,12 @@ publishing {
         mavenLocal()
     }
 }
+
+test {
+    testLogging {
+        events "passed", "skipped", "failed"
+        exceptionFormat "full"
+        // Uncomment the following line if you want to see test logs in gradlew run.
+        // showStandardStreams true
+    }
+}

src/main/java/com/uber/cadence/internal/testservice/TestWorkflowService.java

@@ -106,6 +106,8 @@ public final class TestWorkflowService implements IWorkflowService {
   // key->WorkflowId
   private final Map<WorkflowId, TestWorkflowMutableState> executionsByWorkflowId = new HashMap<>();
 
+  private final ForkJoinPool forkJoinPool = new ForkJoinPool(4);
+
   public void close() {
     store.close();
   }
@@ -565,17 +567,15 @@ public void StartWorkflowExecution(
   public void GetWorkflowExecutionHistory(
       GetWorkflowExecutionHistoryRequest getRequest, AsyncMethodCallback resultHandler)
       throws TException {
-    ForkJoinPool.commonPool()
-        .execute(
-            () -> {
-              try {
-                GetWorkflowExecutionHistoryResponse result =
-                    GetWorkflowExecutionHistory(getRequest);
-                resultHandler.onComplete(result);
-              } catch (TException e) {
-                resultHandler.onError(e);
-              }
-            });
+    forkJoinPool.execute(
+        () -> {
+          try {
+            GetWorkflowExecutionHistoryResponse result = GetWorkflowExecutionHistory(getRequest);
+            resultHandler.onComplete(result);
+          } catch (TException e) {
+            resultHandler.onError(e);
+          }
+        });
   }
 
   @Override

src/test/java/com/uber/cadence/internal/testing/WorkflowTestingTest.java

@@ -68,8 +68,11 @@
 import org.junit.rules.TestWatcher;
 import org.junit.rules.Timeout;
 import org.junit.runner.Description;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class WorkflowTestingTest {
+  private static final Logger log = LoggerFactory.getLogger(WorkflowTestingTest.class);
 
   @Rule public Timeout globalTimeout = Timeout.seconds(5);
 
@@ -84,7 +87,7 @@ protected void failed(Throwable e, Description description) {
 
   private static final String TASK_LIST = "test-workflow";
 
-  private static TestWorkflowEnvironment testEnvironment;
+  private TestWorkflowEnvironment testEnvironment;
 
   @Before
   public void setUp() {
@@ -469,7 +472,7 @@ public void testConcurrentDecision() throws ExecutionException, InterruptedExcep
     CompletableFuture<String> result = WorkflowClient.execute(workflow::workflow1, "input1");
     workflow.ProcessSignal("signalInput");
     assertEquals("signalInput-input1", result.get());
-    System.out.println(testEnvironment.getDiagnostics());
+    log.info(testEnvironment.getDiagnostics());
   }
 
   public interface TestCancellationActivity {

src/test/java/com/uber/cadence/workflow/WorkflowTest.java

@@ -103,7 +103,11 @@ public class WorkflowTest {
 
   @Parameters(name = "{1}")
   public static Object[] data() {
-    return new Object[][] {{true, "Docker"}, {false, "TestService"}};
+    if (Boolean.parseBoolean(System.getenv("SKIP_DOCKER_SERVICE"))) {
+      return new Object[][] {{false, "TestService"}};
+    } else {
+      return new Object[][] {{true, "Docker"}, {false, "TestService"}};
+    }
   }
 
   @Rule public TestName testName = new TestName();