code: @Override
      public void cancelTimeouts(final String sagaId) {
          checkNotNull(sagaId, "SagaId parameter must not be null.");
  
          synchronized (sync) {
              Collection<TimeoutId> timeoutsToRemove = new ArrayList<>();
              Map<TimeoutId, ScheduledFuture> sagaTimeouts = openTimeouts.column(sagaId);
  
              for (Map.Entry<TimeoutId, ScheduledFuture> timeout : sagaTimeouts.entrySet()) {
                  timeout.getValue().cancel(false);
                  timeoutsToRemove.add(timeout.getKey());
              }
  
              for (TimeoutId idToRemove : timeoutsToRemove) {
                  openTimeouts.remove(idToRemove, sagaId);
              }
          }
      }
docs: {@inheritDoc}