|
15 | 15 |
|
16 | 16 | import java.lang.reflect.Constructor; |
17 | 17 | import java.lang.reflect.InvocationTargetException; |
18 | | -import java.util.ArrayList; |
19 | | -import java.util.HashMap; |
20 | | -import java.util.List; |
21 | | -import java.util.Map; |
22 | | -import java.util.Optional; |
| 18 | +import java.util.*; |
23 | 19 | import java.util.stream.Collectors; |
24 | 20 |
|
25 | 21 | import static io.iworkflow.core.WorkflowState.shouldSkipWaitUntil; |
@@ -495,6 +491,20 @@ public void signalWorkflow( |
495 | 491 | signalWorkflow(workflowClass, workflowId, "", signalChannelName, signalValue); |
496 | 492 | } |
497 | 493 |
|
| 494 | + /** |
| 495 | + * Send a single empty message to internalChannel |
| 496 | + * |
| 497 | + * @param workflowClass required |
| 498 | + * @param workflowId required |
| 499 | + * @param internalChannelName required |
| 500 | + * @throws NoRunningWorkflowException if the workflow is not existing or not running |
| 501 | + */ |
| 502 | + public void publishToInternalChannel( |
| 503 | + final Class<? extends ObjectWorkflow> workflowClass, |
| 504 | + final String workflowId, |
| 505 | + final String internalChannelName) { |
| 506 | + publishToInternalChannel(workflowClass, workflowId, "", internalChannelName, null); |
| 507 | + } |
498 | 508 |
|
499 | 509 | /** |
500 | 510 | * Send a single message to internalChannel |
@@ -529,7 +539,7 @@ public void publishToInternalChannel( |
529 | 539 | final String workflowRunId, |
530 | 540 | final String internalChannelName, |
531 | 541 | final Object channelMessage) { |
532 | | - publishToInternalChannelBatch(workflowClass, workflowId, workflowRunId, internalChannelName, channelMessage); |
| 542 | + publishToInternalChannelBatch(workflowClass, workflowId, workflowRunId, internalChannelName, Arrays.asList(channelMessage)); |
533 | 543 | } |
534 | 544 |
|
535 | 545 | /** |
|
0 commit comments