private BundleContext bundleContext;
- private Long defaultTimeout = 120 * 1000l;
+ private Long defaultTimeout = 30 * 1000l;
private Long pollingPeriod = 200l;
// Refresh sync objects
}
@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);
return (T) bundleContext.getService(sfs[0]);
}
- public <T> T getSingleServiceStrict(Class<T> clss, String filter) {
- T service = getSingleService(clss, filter);
+ 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) {
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;
}