andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Added more registrations

Browse Source
This commit is contained in:
Trustin Lee 2009-01-08 11:21:49 +00:00
parent 9645ffd251
commit 18fec46a40
1 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/main/java/org/jboss/netty/container/osgi/NettyBundleActivator.java
View File

@ -29,6 +29,8 @@ import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
import org.jboss.netty.channel.ChannelFactory;
import org.jboss.netty.channel.socket.ClientSocketChannelFactory;
import org.jboss.netty.channel.socket.ServerSocketChannelFactory;
import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory;
import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
import org.jboss.netty.channel.socket.oio.OioClientSocketChannelFactory;
@ -52,8 +54,15 @@ public class NettyBundleActivator implements BundleActivator {
public void start(BundleContext ctx) throws Exception {
executor = Executors.newCachedThreadPool();
register(ctx, new NioClientSocketChannelFactory(executor, executor));
register(ctx, new NioServerSocketChannelFactory(executor, executor));
// The default transport is NIO.
register(ctx,
new NioClientSocketChannelFactory(executor, executor),
ClientSocketChannelFactory.class);
register(ctx,
new NioServerSocketChannelFactory(executor, executor),
ServerSocketChannelFactory.class);
register(ctx, new OioClientSocketChannelFactory(executor));
register(ctx, new OioServerSocketChannelFactory(executor, executor));
}
@ -63,16 +72,15 @@ public class NettyBundleActivator implements BundleActivator {
ExecutorShutdownUtil.shutdown(executor);
}
private void register(BundleContext ctx, ChannelFactory factory) {
register(ctx, factory, factory.getClass());
}
private void register(BundleContext ctx, ChannelFactory factory, Class<?> factoryType) {
private void register(BundleContext ctx, ChannelFactory factory, Class<?>... factoryTypes) {
Properties props = new Properties();
props.setProperty("category", "netty");
registrations.add(
ctx.registerService(factoryType.getName(), factory, props));
registrations.add(ctx.registerService(factory.getClass().getName(), factory, props));
for (Class<?> t: factoryTypes) {
registrations.add(ctx.registerService(t.getName(), factory, props));
}
}
private void unregisterAll() {