diff --git a/src/test/java/org/springframework/data/couchbase/BucketCreator.java b/src/test/java/org/springframework/data/couchbase/BucketCreator.java index e944518f..7b07067d 100644 --- a/src/test/java/org/springframework/data/couchbase/BucketCreator.java +++ b/src/test/java/org/springframework/data/couchbase/BucketCreator.java @@ -6,6 +6,8 @@ import org.apache.http.auth.AuthScope; import org.apache.http.auth.UsernamePasswordCredentials; import org.apache.http.impl.client.BasicCredentialsProvider; import org.apache.http.impl.client.DefaultHttpClient; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.InitializingBean; import org.springframework.http.ResponseEntity; import org.springframework.http.client.ClientHttpRequestFactory; @@ -18,6 +20,8 @@ import java.util.Arrays; public class BucketCreator implements InitializingBean { + private final Logger logger = LoggerFactory.getLogger(BucketCreator.class); + private final String hostUri; private final String adminUser; private final String adminPass; @@ -40,21 +44,29 @@ public class BucketCreator implements InitializingBean { String fullUri = hostUri + "/default/buckets/default"; + ResponseEntity entity = null; try { - template.getForEntity(fullUri, String.class); + entity = template.getForEntity(fullUri, String.class); } catch (HttpClientErrorException ex) { + logger.info("Got execpetion while looking for bucket: " + ex.getMessage()); if (ex.getMessage().equals("404 Object Not Found")) { + logger.info("Creating default bucket with admin credentials."); createBucket(); + return; } else { throw new RuntimeException("Could not see if bucket is already created.", ex); } } + + logger.info("Checking for bucket returned status code " + entity.getStatusCode()); } private void createBucket() throws Exception { ClusterManager bucketManager = new ClusterManager(Arrays.asList(new URI(hostUri)), adminUser, adminPass); bucketManager.createDefaultBucket(BucketType.COUCHBASE, 128, 0, true); + + logger.info("Finished creating bucket, sleeping for warmup."); Thread.sleep(5000); bucketManager.shutdown(); }