@@ -333,7 +333,6 @@ public void handleEvent(HistoryEvent event, boolean hasNextEvent) {
333
333
* this batch contains the last events of the history
334
334
*/
335
335
private void handleEventsBatch (WFTBuffer .EventBatch eventBatch , boolean hasNextBatch ) {
336
- System .out .println ("WorkflowStateMachines.handleEventsBatch: " + eventBatch );
337
336
List <HistoryEvent > events = eventBatch .getEvents ();
338
337
if (EventType .EVENT_TYPE_WORKFLOW_EXECUTION_STARTED .equals (events .get (0 ).getEventType ())) {
339
338
for (SdkFlag flag : initialFlags ) {
@@ -532,7 +531,6 @@ private void handleSingleEvent(HistoryEvent event, boolean lastTask, boolean has
532
531
* commands queue.
533
532
*/
534
533
private void handleCommandEvent (HistoryEvent event ) {
535
- System .out .println (" WorkflowStateMachines.handleCommandEvent: EVENT " + event );
536
534
if (handleLocalActivityMarker (event )) {
537
535
return ;
538
536
}
@@ -554,7 +552,6 @@ private void handleCommandEvent(HistoryEvent event) {
554
552
// In this case we don't want to consume a command.
555
553
// That's why peek is used instead of poll.
556
554
CancellableCommand command = commands .peek ();
557
- System .out .println (" WorkflowStateMachines.handleCommandEvent: COMMAND " + command );
558
555
if (command == null ) {
559
556
if (handleNonMatchingVersionMarker (event )) {
560
557
// this event is a version marker for removed getVersion call.
@@ -570,8 +567,6 @@ private void handleCommandEvent(HistoryEvent event) {
570
567
571
568
if (command .isCanceled ()) {
572
569
// Consume and skip the command
573
- System .out .println (
574
- "WorkflowStateMachines.handleCommandEvent: command is canceled " + command );
575
570
commands .poll ();
576
571
continue ;
577
572
}
@@ -606,9 +601,6 @@ private void handleCommandEvent(HistoryEvent event) {
606
601
607
602
if (command .isCanceled ()) {
608
603
// Consume and skip the command
609
- System .out .println (
610
- "WorkflowStateMachines.handleCommandEvent: command is canceled after handleEvent "
611
- + command );
612
604
commands .poll ();
613
605
continue ;
614
606
}
0 commit comments