/*
- * Copyright (C) 2010 Mathieu Baudier <mbaudier@argeo.org>
+ * Copyright (C) 2007-2012 Mathieu Baudier
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.argeo.slc.osgi;
import org.apache.commons.logging.Log;
private BundleContext bundleContext;
- private Long defaultTimeout = 120 * 1000l;
+ private Long defaultTimeout = 30 * 1000l;
private Long pollingPeriod = 200l;
// Refresh sync objects
try {
Thread.sleep(pollingPeriod);
} catch (InterruptedException e) {
- // silent
+ throw new SlcException("Polling interrupted");
}
}
return (T) bundleContext.getService(sfs[0]);
}
- public <T> T getSingleServiceStrict(Class<T> clss, String filter) {
- T service = getSingleService(clss, filter, true);
+ public <T> T getSingleServiceStrict(Class<T> clss, String filter,
+ Boolean synchronous) {
+ T service = getSingleService(clss, filter, synchronous);
if (service == null)
throw new SlcException("No execution flow found for " + filter);
else
return service;
}
- /** @return the related bundle or null if not found */
+ /**
+ * @param osgiBundle
+ * cannot be null
+ * @return the related bundle or null if not found
+ */
public Bundle findRelatedBundle(OsgiBundle osgiBundle) {
Bundle bundle = null;
if (osgiBundle.getInternalBundleId() != null) {
bundle.getHeaders().get(
Constants.BUNDLE_VERSION)),
"version consistent");
- } else if (osgiBundle.getVersion() == null) {
+ } else if (osgiBundle.getVersion() == null
+ || osgiBundle.getVersion().equals("0.0.0")) {
bundle = OsgiBundleUtils.findBundleBySymbolicName(bundleContext,
osgiBundle.getName());
} else {// scan all bundles
this.defaultTimeout = defaultTimeout;
}
- /** Temporary internal access for {@link OsgiExecutionModulesManager} */
- BundleContext getBundleContext() {
+ /**
+ * Use with caution since it may interfer with some cached information
+ * within this object
+ */
+ public BundleContext getBundleContext() {
return bundleContext;
}