ListKeys.java

package keylist;

import com.couchbase.client.TapClient;
import net.spy.memcached.tapmessage.TapMagic;
import net.spy.memcached.tapmessage.TapOpcode;
import net.spy.memcached.tapmessage.TapRequestFlag;
import net.spy.memcached.tapmessage.RequestMessage;
import net.spy.memcached.tapmessage.ResponseMessage;
import java.net.URI;
import java.util.ArrayList;

public class ListKeys {

    public static void main(String[] args) throws Exception {
        final RequestMessage dumprequest = new RequestMessage();
        dumprequest.setName("listkeys");
        dumprequest.setMagic(TapMagic.PROTOCOL_BINARY_REQ);
        dumprequest.setOpcode(TapOpcode.REQUEST);
        dumprequest.setFlags(TapRequestFlag.DUMP);
        dumprequest.setFlags(TapRequestFlag.KEYS_ONLY);

        final ArrayList<URI> urilist = new ArrayList<URI>();
        urilist.add(new URI("http://mango.hq.couchbase.com:8091/pools"));
        // Couchbase URL, bucket, password
        final TapClient tapclient = new TapClient(urilist, "cbfs","");
        tapclient.tapCustom("listkeys", dumprequest);

        while(tapclient.hasMoreMessages()) {
            ResponseMessage msg = tapclient.getNextMessage();
            if(msg != null) {
                System.out.println("Got key: " + msg.getKey());
            }
        }
    }

}