Change-Id: Id08ad375b27838637497dd507df0c076bf2b63df
Signed-off-by: Thanh Ha <thanh.ha@linuxfoundation.org>
@Override
public void stop(BundleContext context) throws Exception {
@Override
public void stop(BundleContext context) throws Exception {
- if (brokerServiceTracker != null)
+ if (brokerServiceTracker != null) {
brokerServiceTracker.close();
brokerServiceTracker.close();
synchronized (toClose) {
for (AutoCloseable close : toClose) {
synchronized (toClose) {
for (AutoCloseable close : toClose) {
@Override
public void modifiedService(ServiceReference<Broker> reference, Broker service) {
@Override
public void modifiedService(ServiceReference<Broker> reference, Broker service) {
Broker broker = bundleContext.getService(reference);
session = broker.registerProvider(this, bundleContext);
Broker broker = bundleContext.getService(reference);
session = broker.registerProvider(this, bundleContext);