public Operation newOp(final MemcachedNode n,
          final CountDownLatch latch) {
        Operation op =  conn.getOpFactory().tapDump(id,
            new TapOperation.Callback() {
            public void receivedStatus(OperationStatus status) {
            }
            public void gotData(ResponseMessage tapMessage) {
              rqueue.add(tapMessage);
              messagesRead++;
            }
            public void gotAck(MemcachedNode node, TapOpcode opcode,
                int opaque) {
              rqueue.add(new TapAck(conn, node, opcode, opaque, this));
            }
            public void complete() {
              latch.countDown();
            }
          });
        ts.addOp((TapOperation)op);
        return op;
      }
Specifies a tap stream that will take a snapshot of items in memcached and
send them through a tap stream.

@param id the named tap id that can be used to resume a disconnected tap
         stream
@return the operation that controls the tap stream.
@throws ConfigurationException a bad configuration was received from the
          memcached cluster.
@throws IOException If there are errors connecting to the cluster.
src/main/java/net/spy/memcached/TapClient.java