+/*
+ * Copyright (C) 2010 Mathieu Baudier <mbaudier@argeo.org>
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * 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 = 10000l;
- private Long pollingPeriod = 100l;
+ private Long defaultTimeout = 30 * 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);
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) {
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;
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;
}