{
private BundleContext bundleContext;
- public NettyThreadgroupModule(org.opendaylight.controller.config.api.ModuleIdentifier name, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
+ public NettyThreadgroupModule(final org.opendaylight.controller.config.api.ModuleIdentifier name, final org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
super(name, dependencyResolver);
}
- public NettyThreadgroupModule(org.opendaylight.controller.config.api.ModuleIdentifier name, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, NettyThreadgroupModule oldModule, java.lang.AutoCloseable oldInstance) {
+ public NettyThreadgroupModule(final org.opendaylight.controller.config.api.ModuleIdentifier name, final org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, final NettyThreadgroupModule oldModule, final java.lang.AutoCloseable oldInstance) {
super(name, dependencyResolver, oldModule, oldInstance);
}
return Reflection.newProxy(AutoCloseableEventLoopGroupInterface.class, new AbstractInvocationHandler() {
@Override
- protected Object handleInvocation(Object proxy, Method method, Object[] args) throws Throwable {
+ protected Object handleInvocation(final Object proxy, final Method method, final Object[] args) throws Throwable {
if (method.getName().equals("close")) {
tracker.close();
return null;
});
}
- public void setBundleContext(BundleContext bundleContext) {
+ public void setBundleContext(final BundleContext bundleContext) {
this.bundleContext = bundleContext;
}
@Deprecated
public class NettyThreadgroupModuleFactory extends AbstractNettyThreadgroupModuleFactory {
@Override
- public NettyThreadgroupModule instantiateModule(String instanceName, DependencyResolver dependencyResolver,
- NettyThreadgroupModule oldModule, AutoCloseable oldInstance, BundleContext bundleContext) {
+ public NettyThreadgroupModule instantiateModule(final String instanceName, final DependencyResolver dependencyResolver,
+ final NettyThreadgroupModule oldModule, final AutoCloseable oldInstance, final BundleContext bundleContext) {
NettyThreadgroupModule module = super.instantiateModule(instanceName, dependencyResolver, oldModule, oldInstance, bundleContext);
module.setBundleContext(bundleContext);
return module;
}
@Override
- public NettyThreadgroupModule instantiateModule(String instanceName, DependencyResolver dependencyResolver,
- BundleContext bundleContext) {
+ public NettyThreadgroupModule instantiateModule(final String instanceName, final DependencyResolver dependencyResolver,
+ final BundleContext bundleContext) {
NettyThreadgroupModule module = super.instantiateModule(instanceName, dependencyResolver, bundleContext);
module.setBundleContext(bundleContext);
return module;
import java.util.concurrent.TimeUnit;
public class NioEventLoopGroupCloseable extends NioEventLoopGroup implements AutoCloseable {
- private NioEventLoopGroupCloseable(int threadCount) {
+ private NioEventLoopGroupCloseable(final int threadCount) {
super(threadCount);
}
shutdownGracefully(0, 1, TimeUnit.SECONDS);
}
- public static NioEventLoopGroupCloseable newInstance(Integer threadCount) {
+ public static NioEventLoopGroupCloseable newInstance(final Integer threadCount) {
if(threadCount == null || threadCount <= 0) {
return new NioEventLoopGroupCloseable();
}
assertStatus(status, 0, 1, 0);
}
- private ObjectName createInstance(ConfigTransactionJMXClient transaction, String instanceName, Integer threads)
+ private ObjectName createInstance(final ConfigTransactionJMXClient transaction, final String instanceName, final Integer threads)
throws InstanceAlreadyExistsException {
ObjectName nameCreated = transaction.createModule(factory.getImplementationName(), instanceName);
NettyThreadgroupModuleMXBean mxBean = transaction.newMBeanProxy(nameCreated, NettyThreadgroupModuleMXBean.class);