code: @Override
      protected void nibble(Queue<DuplicationMorsel> queue) {
          DuplicationMorsel morsel = queue.poll();
          String account = morsel.getAccount();
          String spaceId = morsel.getSpaceId();
          DuplicationStorePolicy storePolicy = morsel.getStorePolicy();
  
          //get all items from source
          StorageProvider sourceProvider =
              getStorageProvider(account, storePolicy.getSrcStoreId());
          StorageProvider destProvider =
              getStorageProvider(account, storePolicy.getDestStoreId());
  
          if (!morsel.isDeletePerformed()) {
              addDuplicationTasksForContentNotInSource(account,
                                                       spaceId,
                                                       storePolicy,
                                                       sourceProvider,
                                                       destProvider);
              morsel.setDeletePerformed(true);
          }
  
          int maxTaskQueueSize = getMaxTaskQueueSize();
          int taskQueueSize = getTaskQueue().size();
          if (taskQueueSize >= maxTaskQueueSize) {
              log.info("Task queue size ({}) has reached or exceeded max size ({}).",
                       taskQueueSize, maxTaskQueueSize);
              addToReloadList(morsel);
          } else {
              if (addDuplicationTasksFromSource(morsel, sourceProvider, 1000)) {
                  log.info("All tasks that could be created were created for account={}, spaceId={}, storePolicy={}. " +
                           "getTaskQueue().size = {}", account, spaceId, storePolicy, getTaskQueue().size());
                  log.info("morsel completely nibbled. No reload necessary in this round.", morsel);
              } else {
                  log.info("morsel nibbled a bit: {}", morsel);
                  addToReloadList(morsel);
              }
  
          }
      }
docs: /* (non-Javadoc)
  @see org.duracloud.mill.ltp.LoopingTaskProducer#nibble(org.duracloud.mill.ltp.Queue<T>)