Buckets.java

public static ReactiveCouchbaseDriver driver = ReactiveCouchbaseDriver.apply();

public static org.reactivecouchbase.play.java.CouchbaseBucket getBucket(String name) throws Exception {
    org.reactivecouchbase.CouchbaseBucket scalaBucket = driver.bucket(name);
    Class<org.reactivecouchbase.play.java.CouchbaseBucket> clazz = org.reactivecouchbase.play.java.CouchbaseBucket.class;
    Constructor<?> constructor = Arrays.asList(clazz.getDeclaredConstructors()).iterator().next();
    constructor.setAccessible(true);
    return (org.reactivecouchbase.play.java.CouchbaseBucket) constructor.newInstance(scalaBucket);
}