private BundleContext bundleContext;
- private Long defaultTimeout = 10000l;
- private Long pollingPeriod = 100l;
+ private Long defaultTimeout = 120 * 1000l;
+ private Long pollingPeriod = 200l;
// Refresh sync objects
private final Object refreshedPackageSem = new Object();
}
@SuppressWarnings(value = { "unchecked" })
- public <T> T getSingleService(Class<T> clss, String filter) {
+ public <T> T getSingleService(Class<T> clss, String filter,
+ Boolean synchronous) {
Assert.isTrue(OsgiFilterUtils.isValidFilter(filter), "valid filter");
ServiceReference[] sfs;
try {
- sfs = bundleContext.getServiceReferences(clss.getName(), filter);
+ if (synchronous)
+ sfs = getServiceRefSynchronous(clss.getName(), filter);
+ else
+ sfs = bundleContext
+ .getServiceReferences(clss.getName(), filter);
} catch (InvalidSyntaxException e) {
throw new SlcException("Cannot retrieve service reference for "
+ filter, e);
}
public <T> T getSingleServiceStrict(Class<T> clss, String filter) {
- T service = getSingleService(clss, filter);
+ T service = getSingleService(clss, filter, true);
if (service == null)
throw new SlcException("No execution flow found for " + filter);
else
osgiBundle.getName().equals(bundle.getSymbolicName()),
"symbolic name consistent");
if (osgiBundle.getVersion() != null)
- Assert.isTrue(osgiBundle.getVersion().equals(
- bundle.getHeaders().get(Constants.BUNDLE_VERSION)),
+ Assert.isTrue(
+ osgiBundle.getVersion().equals(
+ bundle.getHeaders().get(
+ Constants.BUNDLE_VERSION)),
"version consistent");
} else if (osgiBundle.getVersion() == null) {
bundle = OsgiBundleUtils.findBundleBySymbolicName(bundleContext,
break bundles;
}
- if (b.getHeaders().get(Constants.BUNDLE_VERSION).equals(
- osgiBundle.getVersion())) {
+ if (b.getHeaders().get(Constants.BUNDLE_VERSION)
+ .equals(osgiBundle.getVersion())) {
bundle = b;
osgiBundle.setInternalBundleId(b.getBundleId());
break bundles;