import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@Deprecated(forRemoval = true)
public class RootBindingAwareBroker implements Mutable, Identifiable<String>, BindingAwareBroker, AutoCloseable,
RpcProviderRegistry {
- private final static Logger LOG = LoggerFactory.getLogger(RootBindingAwareBroker.class);
+ private static final Logger LOG = LoggerFactory.getLogger(RootBindingAwareBroker.class);
RootSalInstance controllerRoot;
return registerConsumer(consumer);
}
- @Override
- public ProviderContext registerProvider(final BindingAwareProvider provider, final BundleContext ctx) {
- return registerProvider(provider);
- }
-
@Override
public ConsumerContext registerConsumer(final BindingAwareConsumer consumer) {
checkState(supportedConsumerServices != null, "Broker is not initialized.");
return BindingContextUtils.createConsumerContextAndInitialize(consumer, supportedConsumerServices);
}
+ @Override
+ public ProviderContext registerProvider(final BindingAwareProvider provider, final BundleContext ctx) {
+ return registerProvider(provider);
+ }
+
@Override
public ProviderContext registerProvider(final BindingAwareProvider provider) {
checkState(supportedProviderServices != null, "Broker is not initialized.");
}
@Override
- public void close() throws Exception {
+ public void close() {
// FIXME: Close all sessions
}
}
@Override
- public <L extends RouteChangeListener<RpcContextIdentifier, InstanceIdentifier<?>>> ListenerRegistration<L> registerRouteChangeListener(
- final L arg0) {
- return getRoot().registerRouteChangeListener(arg0);
+ public <L extends RouteChangeListener<RpcContextIdentifier, InstanceIdentifier<?>>> ListenerRegistration<L>
+ registerRouteChangeListener(final L listener) {
+ return getRoot().registerRouteChangeListener(listener);
}
- public class RootSalInstance extends
+ public static class RootSalInstance extends
AbstractBindingSalProviderInstance<NotificationProviderService, RpcProviderRegistry> {
public RootSalInstance(final RpcProviderRegistry rpcRegistry,
super(rpcRegistry, notificationBroker);
}
}
-
}