Worker and Options refactoring part 2 (#552)

* This diff mainly moved worker.factory and worker.factory.option to their own files.
* This is a BREAKING change.

Author: meiliang86

src/main/java/com/uber/cadence/client/ActivityWorkerShutdownException.java

@@ -21,10 +21,10 @@
 import java.util.concurrent.TimeUnit;
 
 /**
- * Indicates that {@link com.uber.cadence.worker.Worker.Factory#shutdown()} or {@link
- * com.uber.cadence.worker.Worker.Factory#shutdownNow()} was called. It is OK to ignore the
- * exception to let activity to complete. It assumes that {@link
- * com.uber.cadence.worker.Worker.Factory#awaitTermination(long, TimeUnit)} is called with a timeout
+ * Indicates that {@link com.uber.cadence.worker.WorkerFactory#shutdown()} or {@link
+ * com.uber.cadence.worker.WorkerFactory#shutdownNow()} was called. It is OK to ignore the exception
+ * to let activity to complete. It assumes that {@link
+ * com.uber.cadence.worker.WorkerFactory#awaitTermination(long, TimeUnit)} is called with a timeout
  * larger than the activity execution time.
  */
 public final class ActivityWorkerShutdownException extends ActivityCompletionException {

src/main/java/com/uber/cadence/client/WorkflowClientOptions.java

@@ -17,10 +17,16 @@
 
 package com.uber.cadence.client;
 
+import com.uber.cadence.context.ContextPropagator;
 import com.uber.cadence.converter.DataConverter;
 import com.uber.cadence.converter.JsonDataConverter;
+import com.uber.cadence.internal.metrics.MetricsTag;
 import com.uber.cadence.internal.metrics.NoopScope;
 import com.uber.m3.tally.Scope;
+import com.uber.m3.util.ImmutableMap;
+import java.lang.management.ManagementFactory;
+import java.util.Arrays;
+import java.util.List;
 import java.util.Objects;
 
 /** Options for WorkflowClient configuration. */
@@ -29,6 +35,7 @@ public final class WorkflowClientOptions {
   private static final WorkflowClientOptions DEFAULT_INSTANCE;
   private static final WorkflowClientInterceptor[] EMPTY_INTERCEPTOR_ARRAY =
       new WorkflowClientInterceptor[0];
+  private static final List<ContextPropagator> EMPTY_CONTEXT_PROPAGATORS = Arrays.asList();
 
   static {
     DEFAULT_INSTANCE = new Builder().build();
@@ -51,6 +58,8 @@ public static final class Builder {
     private DataConverter dataConverter = JsonDataConverter.getInstance();
     private WorkflowClientInterceptor[] interceptors = EMPTY_INTERCEPTOR_ARRAY;
     private Scope metricsScope = NoopScope.getInstance();
+    private String identity = ManagementFactory.getRuntimeMXBean().getName();;
+    private List<ContextPropagator> contextPropagators = EMPTY_CONTEXT_PROPAGATORS;
 
     private Builder() {}
 
@@ -59,6 +68,7 @@ private Builder(WorkflowClientOptions options) {
       dataConverter = options.getDataConverter();
       interceptors = options.getInterceptors();
       metricsScope = options.getMetricsScope();
+      identity = options.getIdentity();
     }
 
     public Builder setDomain(String domain) {
@@ -97,25 +107,49 @@ public Builder setMetricsScope(Scope metricsScope) {
       return this;
     }
 
+    /**
+     * Override human readable identity of the worker. Identity is used to identify a worker and is
+     * recorded in the workflow history events. For example when a worker gets an activity task the
+     * correspondent ActivityTaskStarted event contains the worker identity as a field. Default is
+     * whatever <code>(ManagementFactory.getRuntimeMXBean().getName()</code> returns.
+     */
+    public Builder setIdentity(String identity) {
+      this.identity = Objects.requireNonNull(identity);
+      return this;
+    }
+
+    public Builder setContextPropagators(List<ContextPropagator> contextPropagators) {
+      this.contextPropagators = contextPropagators;
+      return this;
+    }
+
     public WorkflowClientOptions build() {
-      return new WorkflowClientOptions(domain, dataConverter, interceptors, metricsScope);
+      metricsScope = metricsScope.tagged(ImmutableMap.of(MetricsTag.DOMAIN, domain));
+      return new WorkflowClientOptions(
+          domain, dataConverter, interceptors, metricsScope, identity, contextPropagators);
     }
   }
 
   private final String domain;
   private final DataConverter dataConverter;
   private final WorkflowClientInterceptor[] interceptors;
   private final Scope metricsScope;
+  private String identity;
+  private List<ContextPropagator> contextPropagators;
 
   private WorkflowClientOptions(
       String domain,
       DataConverter dataConverter,
       WorkflowClientInterceptor[] interceptors,
-      Scope metricsScope) {
+      Scope metricsScope,
+      String identity,
+      List<ContextPropagator> contextPropagators) {
     this.domain = domain;
     this.dataConverter = dataConverter;
     this.interceptors = interceptors;
     this.metricsScope = metricsScope;
+    this.identity = identity;
+    this.contextPropagators = contextPropagators;
   }
 
   public String getDomain() {
@@ -133,4 +167,12 @@ public WorkflowClientInterceptor[] getInterceptors() {
   public Scope getMetricsScope() {
     return metricsScope;
   }
+
+  public String getIdentity() {
+    return identity;
+  }
+
+  public List<ContextPropagator> getContextPropagators() {
+    return contextPropagators;
+  }
 }