@Override
  public void dispose() {
    synchronized (mySessions) {
      for (var session : mySessions) {
        session.cancel();
      }
    }
    myEventProcessingQueue.cancel();
    myQueue.cancel();
  }
@Override
  public void dispose()