in commands/src/main/java/org/jclouds/karaf/commands/blobstore/BlobStoreServiceCreateCommand.java [193:218]
public synchronized BlobStore waitForBlobStore(BundleContext bundleContext, String name, String provider, String api) {
BlobStore blobStore = null;
try {
for (int r = 0; r < 6; r++) {
ServiceReference[] references = null;
if (name != null) {
references = bundleContext.getAllServiceReferences(BlobStore.class.getName(), "("+Constants.NAME+"="
+ name + ")");
}
if (provider != null) {
references = bundleContext.getAllServiceReferences(BlobStore.class.getName(), "("+Constants.PROVIDER+"=" + provider
+ ")");
} else if (api != null) {
references = bundleContext.getAllServiceReferences(BlobStore.class.getName(), "("+Constants.API+"=" + api + ")");
}
if (references != null && references.length > 0) {
blobStore = (BlobStore) bundleContext.getService(references[0]);
return blobStore;
}
Thread.sleep(10000L);
}
} catch (Exception e) {
// noop
}
return blobStore;
}