docs: void onPartitionMigrate(MigrationInfo migrationInfo) {
          Iterator<WaitSetEntry> it = queue.iterator();
          int partitionId = migrationInfo.getPartitionId();
          while (it.hasNext()) {
              if (Thread.currentThread().isInterrupted()) {
                  return;
              }
              WaitSetEntry entry = it.next();
              if (!entry.isValid()) {
                  continue;
              }
  
              Operation op = entry.getOperation();
              if (partitionId == op.getPartitionId()) {
                  entry.setValid(false);
                  PartitionMigratingException pme = new PartitionMigratingException(nodeEngine.getThisAddress(),
                          partitionId, op.getClass().getName(), op.getServiceName());
                  op.sendResponse(pme);
                  it.remove();
              }
          }
      }