rename samples package

Author: halakaraki

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

@@ -30,17 +30,19 @@
 import com.uber.cadence.testing.TestEnvironmentOptions.Builder;
 import com.uber.cadence.testing.TestWorkflowEnvironment;
 import com.uber.cadence.worker.Worker;
-import com.uber.cadence.workflow.interceptors.CorruptedSignalWorkflowInterceptorFactory;
-import com.uber.cadence.workflow.samples.ReceiveSignalObject_ChildWorkflowImpl;
-import com.uber.cadence.workflow.samples.SendSignalObject_Workflow;
-import com.uber.cadence.workflow.samples.SendSignalObject_WorkflowImpl;
+import com.uber.cadence.workflow.interceptors.SignalWorkflowInterceptor;
+import com.uber.cadence.workflow.workflows.ReceiveSignalObject_ChildWorkflowImpl;
+import com.uber.cadence.workflow.workflows.SendSignalObject_Workflow;
+import com.uber.cadence.workflow.workflows.SendSignalObject_WorkflowImpl;
 import com.uber.m3.tally.RootScopeBuilder;
 import com.uber.m3.tally.Scope;
 import com.uber.m3.tally.StatsReporter;
 import com.uber.m3.tally.Stopwatch;
 import com.uber.m3.util.ImmutableMap;
 import java.time.Duration;
 import java.util.Map;
+import java.util.function.Function;
+
 import org.junit.Before;
 import org.junit.Rule;
 import org.junit.Test;
@@ -191,4 +193,18 @@ public void testCorruptedSignalMetrics() throws InterruptedException {
                     .build();
     verify(reporter, times(1)).reportCounter(MetricsType.CORRUPTED_SIGNALS_COUNTER, tags, 2);
   }
+
+  private static class CorruptedSignalWorkflowInterceptorFactory
+          implements Function<WorkflowInterceptor, WorkflowInterceptor> {
+
+      @Override
+      public WorkflowInterceptor apply(WorkflowInterceptor next) {
+          return new SignalWorkflowInterceptor(args -> {
+                      if(args != null && args.length > 0){
+                          return new Object [] {"Corrupted Signal"};
+                      }
+                      return args;
+                  }, sig->sig, next);
+      }
+  }
 }

src/test/java/com/uber/cadence/workflow/interceptors/CorruptedSignalWorkflowInterceptorFactory.java

@@ -15,11 +15,10 @@
  *  permissions and limitations under the License.
  */
 
-package com.uber.cadence.workflow.samples;
+package com.uber.cadence.workflow.workflows;
 
 import com.uber.cadence.workflow.SignalMethod;
 import com.uber.cadence.workflow.WorkflowMethod;
-import com.uber.cadence.workflow.samples.Signal;
 
 public interface ReceiveSignalObject_ChildWorkflow {
 

src/test/java/com/uber/cadence/workflow/samples/ReceiveSignalObject_ChildWorkflow.java renamed to src/test/java/com/uber/cadence/workflow/workflows/ReceiveSignalObject_ChildWorkflow.java

@@ -15,11 +15,10 @@
  *  permissions and limitations under the License.
  */
 
-package com.uber.cadence.workflow.samples;
+package com.uber.cadence.workflow.workflows;
 
 import com.uber.cadence.workflow.CompletablePromise;
 import com.uber.cadence.workflow.Workflow;
-import com.uber.cadence.workflow.WorkflowTest;
 
 public class ReceiveSignalObject_ChildWorkflowImpl implements ReceiveSignalObject_ChildWorkflow {
       private String receivedSignal = "Initial State";

src/test/java/com/uber/cadence/workflow/samples/ReceiveSignalObject_ChildWorkflowImpl.java renamed to src/test/java/com/uber/cadence/workflow/workflows/ReceiveSignalObject_ChildWorkflowImpl.java

@@ -15,7 +15,7 @@
  *  permissions and limitations under the License.
  */
 
-package com.uber.cadence.workflow.samples;
+package com.uber.cadence.workflow.workflows;
 
 import com.uber.cadence.workflow.WorkflowMethod;
 

src/test/java/com/uber/cadence/workflow/samples/SendSignalObject_Workflow.java renamed to src/test/java/com/uber/cadence/workflow/workflows/SendSignalObject_Workflow.java

@@ -15,14 +15,11 @@
  *  permissions and limitations under the License.
  */
 
-package com.uber.cadence.workflow.samples;
+package com.uber.cadence.workflow.workflows;
 
 import com.uber.cadence.workflow.Async;
 import com.uber.cadence.workflow.Promise;
 import com.uber.cadence.workflow.Workflow;
-import com.uber.cadence.workflow.samples.ReceiveSignalObject_ChildWorkflow;
-import com.uber.cadence.workflow.samples.SendSignalObject_Workflow;
-import com.uber.cadence.workflow.samples.Signal;
 
 public class SendSignalObject_WorkflowImpl implements SendSignalObject_Workflow {
   @Override

src/test/java/com/uber/cadence/workflow/samples/SendSignalObject_WorkflowImpl.java renamed to src/test/java/com/uber/cadence/workflow/workflows/SendSignalObject_WorkflowImpl.java

@@ -15,7 +15,7 @@
  *  permissions and limitations under the License.
  */
 
-package com.uber.cadence.workflow.samples;
+package com.uber.cadence.workflow.workflows;
 
 public class Signal {