code: @Override
      public void changed(EventType type, Object o, BlockingQueue queue) {
          if ((type == EventType.PUT || type == EventType.ADD) &&
                  isContinuous() &&
                  !queue.isEmpty()) {
  
              synchronized (lockWaitForPendingFutures) {
                  if (waitingForPendingFutures) {
                      return;
                  }
              }
  
              fireTrigger(ReplicationTrigger.RESUME);
              waitForPendingFuturesWithNewThread();
          }
      }
docs: Implementation of BlockingQueueListener.changed(EventType, Object, BlockingQueue) for Pull Replication
  <p/>
  Note: Pull replication needs to send IDLE after PUT /{db}/_local.
  However sending IDLE from Push replicator breaks few unit test cases.
  This is reason changed() method was override for pull replication