@Override
  public void tryStartBundle() {
    inconsistentStateCheck();

    LOG.debug(
        "tryStartBundle: elementCount={}, Bundle={}", currentBundleElementCount, this.toString());

    if (isBundleStarted.compareAndSet(false, true)) {
      LOG.debug("Starting a new bundle.");
      bundleStartTime.set(System.currentTimeMillis());
      pendingBundleCount.getAndIncrement();
      bundleProgressListener.onBundleStarted();
    }

    currentBundleElementCount.incrementAndGet();
  }
@Test
  public void test() {
    portableBundleManager =
        new PortableBundleManager<>(
            bundleProgressListener, 1, MAX_BUNDLE_TIME_MS, bundleTimerScheduler, TIMER_ID);
    portableBundleManager.tryStartBundle();

    verify(bundleProgressListener, times(1)).onBundleStarted();
  }