@@ -333,7 +333,6 @@ public void handleEvent(HistoryEvent event, boolean hasNextEvent) {
333333 * this batch contains the last events of the history
334334 */
335335 private void handleEventsBatch (WFTBuffer .EventBatch eventBatch , boolean hasNextBatch ) {
336- System .out .println ("WorkflowStateMachines.handleEventsBatch: " + eventBatch );
337336 List <HistoryEvent > events = eventBatch .getEvents ();
338337 if (EventType .EVENT_TYPE_WORKFLOW_EXECUTION_STARTED .equals (events .get (0 ).getEventType ())) {
339338 for (SdkFlag flag : initialFlags ) {
@@ -532,7 +531,6 @@ private void handleSingleEvent(HistoryEvent event, boolean lastTask, boolean has
532531 * commands queue.
533532 */
534533 private void handleCommandEvent (HistoryEvent event ) {
535- System .out .println (" WorkflowStateMachines.handleCommandEvent: EVENT " + event );
536534 if (handleLocalActivityMarker (event )) {
537535 return ;
538536 }
@@ -554,7 +552,6 @@ private void handleCommandEvent(HistoryEvent event) {
554552 // In this case we don't want to consume a command.
555553 // That's why peek is used instead of poll.
556554 CancellableCommand command = commands .peek ();
557- System .out .println (" WorkflowStateMachines.handleCommandEvent: COMMAND " + command );
558555 if (command == null ) {
559556 if (handleNonMatchingVersionMarker (event )) {
560557 // this event is a version marker for removed getVersion call.
@@ -570,8 +567,6 @@ private void handleCommandEvent(HistoryEvent event) {
570567
571568 if (command .isCanceled ()) {
572569 // Consume and skip the command
573- System .out .println (
574- "WorkflowStateMachines.handleCommandEvent: command is canceled " + command );
575570 commands .poll ();
576571 continue ;
577572 }
@@ -606,9 +601,6 @@ private void handleCommandEvent(HistoryEvent event) {
606601
607602 if (command .isCanceled ()) {
608603 // Consume and skip the command
609- System .out .println (
610- "WorkflowStateMachines.handleCommandEvent: command is canceled after handleEvent "
611- + command );
612604 commands .poll ();
613605 continue ;
614606 }
0 commit comments