Streaming Bucket List with RJC. Reset `young_vclock` when negative.

app.java

package basho;

import java.io.IOException;

import com.basho.riak.client.IRiakClient;
import com.basho.riak.client.RiakException;
import com.basho.riak.client.RiakFactory;
import com.basho.riak.client.bucket.Bucket;
import com.basho.riak.client.query.StreamingOperation;

public class App {

	public static void main(String[] args) throws RiakException, IOException {
		IRiakClient riakClient = RiakFactory
				.httpClient("http://127.0.0.1:8098/riak");

		StreamingOperation<String> bucketNames = riakClient
				.listBucketsStreaming();

		for (String bucketName : bucketNames) {
			Bucket thisBucket = riakClient.fetchBucket(bucketName).execute();
			System.out.print(thisBucket.getName() + " young_vclock = "
					+ thisBucket.getYoungVClock());

			if (thisBucket.getYoungVClock() == -1L) {
				riakClient.createBucket(thisBucket.getName()).youngVClock(20L)
						.execute();
				System.out.printf(" -- RESET TO 20.%n");
			} else {
				System.out.printf(".%n");
			}
		}
		riakClient.shutdown();

	}

}