in services/src/main/java/org/jclouds/karaf/services/internal/BlobStoreServiceFactory.java [59:141]
public synchronized void updated(String pid, Dictionary properties) throws ConfigurationException {
ServiceRegistration newRegistration = null;
try {
if (properties != null) {
Properties props = new Properties();
for (Enumeration e = properties.keys(); e.hasMoreElements(); ) {
Object key = e.nextElement();
Object val = properties.get(key);
props.put(key, val);
}
String provider = (String) properties.get(Constants.PROVIDER);
String api = (String) properties.get(Constants.API);
ProviderMetadata providerMetadata = null;
ApiMetadata apiMetadata = null;
if (!Strings.isNullOrEmpty(provider) && installedProviders.containsKey(provider)) {
providerMetadata = installedProviders.get(provider);
validate(providerMetadata, properties);
} else if (!Strings.isNullOrEmpty(api) && installedApis.containsKey(api)) {
apiMetadata = installedApis.get(api);
validate(apiMetadata, properties);
} else {
if (!Strings.isNullOrEmpty(provider)) {
providerPids.put(provider, pid);
}
if (!Strings.isNullOrEmpty(api)) {
apiPids.put(api, pid);
}
pendingPids.put(pid, properties);
LOGGER.warn("Provider {} or Api {} is not currently installed. Service will resume once the the provider is installed.", provider, api);
return;
}
//We are removing credentials as we don't want them to be visible in the service registration.
String id = (String) properties.get(Constants.NAME);
String identity = (String) properties.remove(Constants.IDENTITY);
String credential = (String) properties.remove(Constants.CREDENTIAL);
String endpoint = (String) properties.get(Constants.ENDPOINT);
BlobStoreContext context = null;
ContextBuilder builder = null;
if (providerMetadata != null) {
builder = ContextBuilder.newBuilder(providerMetadata);
} else if (apiMetadata != null) {
builder = ContextBuilder.newBuilder(apiMetadata);
} else {
return;
}
if (!Strings.isNullOrEmpty(endpoint)) {
builder = builder.endpoint(endpoint);
}
context = builder.name(id).credentials(identity, credential)
.modules(ImmutableSet.<Module>of(new Log4JLoggingModule()))
.overrides(props)
.build(BlobStoreContext.class);
BlobStore blobStore = context.getBlobStore();
newRegistration = bundleContext.registerService(
BlobStore.class.getName(), blobStore, properties);
//If all goes well move the pending pid to the active pids.
if (pendingPids.containsKey(pid)) {
activePids.put(pid, pendingPids.remove(pid));
}
}
} catch (InvalidConfigurationException ex) {
LOGGER.warn("Invalid configuration: {}", ex.getMessage());
} catch (Exception ex) {
LOGGER.error("Error creating blobstore service.", ex);
} finally {
ServiceRegistration oldRegistration = (newRegistration == null)
? registrations.remove(pid)
: registrations.put(pid, newRegistration);
if (oldRegistration != null) {
System.out.println("Unregistering BlobStore " + pid);
oldRegistration.unregister();
}
}
}