use list instead of vararg

Author: longquanzheng

src/main/java/io/iworkflow/core/Client.java

@@ -539,22 +539,22 @@ public void publishToInternalChannel(
      * @param workflowId        required
      * @param workflowRunId     optional, can be empty
      * @param internalChannelName required
-     * @param channelMessages       optional, can be null. messages in batch
+     * @param channelMessages       messages in batch
      * @throws NoRunningWorkflowException  if the workflow is not existing or not running
      */
     public void publishToInternalChannelBatch(
             final Class<? extends ObjectWorkflow> workflowClass,
             final String workflowId,
             final String workflowRunId,
             final String internalChannelName,
-            final Object... channelMessages) {
+            final List<Object> channelMessages) {
         final String wfType = workflowClass.getSimpleName();
 
         checkWorkflowTypeExists(wfType);
 
         final Class<?> channelValueType = registry.getInternalChannelTypeStore(wfType).getType(internalChannelName);
 
-        List<InterStateChannelPublishing> rawMessages = new ArrayList<>(channelMessages.length);
+        List<InterStateChannelPublishing> rawMessages = new ArrayList<>(channelMessages.size());
         for (Object channelValue : channelMessages) {
             if (channelValue != null && !channelValueType.isInstance(channelValue)) {
                 throw new IllegalArgumentException(String.format("message value is not of channel type %s", channelValueType.getName()));

src/test/java/io/iworkflow/integ/InternalChannelTest.java

@@ -10,6 +10,7 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 
+import java.util.Arrays;
 import java.util.concurrent.ExecutionException;
 
 public class InternalChannelTest {
@@ -37,7 +38,7 @@ public void testWaitingInternalWorkflow() throws InterruptedException {
         final Integer input = 1;
         final String runId = client.startWorkflow(
                 WaitingInternalChannelWorkflow.class, wfId, 10, input);
-        client.publishToInternalChannelBatch(WaitingInternalChannelWorkflow.class, wfId,  "",  WaitingInternalChannelWorkflow.INTER_STATE_CHANNEL_NAME, 2, 3);
+        client.publishToInternalChannelBatch(WaitingInternalChannelWorkflow.class, wfId,  runId,  WaitingInternalChannelWorkflow.INTER_STATE_CHANNEL_NAME, Arrays.asList(2, 3));
         final Integer output = client.getSimpleWorkflowResultWithWait(Integer.class, wfId);
         Assertions.assertEquals(6, output);
     }