removePluggableHandlers

This commit is contained in:
Vladimir Krivosheev
2012-08-24 09:44:25 +04:00
parent 3d39927b53
commit b1fc81493b
2 changed files with 9 additions and 1 deletions
@@ -53,7 +53,7 @@ public class XmlRpcServerImpl extends SimpleChannelUpstreamHandler implements Xm
@Override
public void consume(ChannelPipeline pipeline) {
pipeline.addLast("xmlRpc", this);
pipeline.addLast("pluggable_xmlRpc", this);
}
public int getPortNumber() {
@@ -116,6 +116,14 @@ public class WebServer {
Runtime.getRuntime().addShutdownHook(new Thread(createShutdownTask()));
}
public static void removePluggableHandlers(ChannelPipeline pipeline) {
for (String name : pipeline.getNames()) {
if (name.startsWith("pluggable_")) {
pipeline.remove(name);
}
}
}
private static class ChannelPipelineFactoryImpl implements ChannelPipelineFactory {
private final Computable<Consumer<ChannelPipeline>[]> pipelineConsumers;
private final DefaultHandler defaultHandler;