CAMEL-6555 Removed the files which are useless in camel-netty4
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/66ccde63 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/66ccde63 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/66ccde63 Branch: refs/heads/master Commit: 66ccde6317ff099ed8c3e257c45329a93ad36fdc Parents: 6cfee23 Author: Willem Jiang <willem.ji...@gmail.com> Authored: Fri Jul 18 23:13:01 2014 +0800 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Tue Jul 22 21:25:18 2014 +0800 ---------------------------------------------------------------------- .../netty4/CamelNettyThreadNameDeterminer.java | 36 --------- .../netty4/NettyClientBossPoolBuilder.java | 78 -------------------- 2 files changed, 114 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/66ccde63/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/CamelNettyThreadNameDeterminer.java ---------------------------------------------------------------------- diff --git a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/CamelNettyThreadNameDeterminer.java b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/CamelNettyThreadNameDeterminer.java deleted file mode 100644 index 441a763..0000000 --- a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/CamelNettyThreadNameDeterminer.java +++ /dev/null @@ -1,36 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.component.netty4; - -import org.apache.camel.util.concurrent.ThreadHelper; -import io.netty.util.ThreadNameDeterminer; - -public class CamelNettyThreadNameDeterminer implements ThreadNameDeterminer { - - private final String pattern; - private final String name; - - public CamelNettyThreadNameDeterminer(String pattern, String name) { - this.pattern = pattern; - this.name = name; - } - - @Override - public String determineThreadName(String currentThreadName, String proposedThreadName) throws Exception { - return ThreadHelper.resolveThreadName(pattern, name); - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/66ccde63/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyClientBossPoolBuilder.java ---------------------------------------------------------------------- diff --git a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyClientBossPoolBuilder.java b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyClientBossPoolBuilder.java deleted file mode 100644 index f0fc18f..0000000 --- a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyClientBossPoolBuilder.java +++ /dev/null @@ -1,78 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.component.netty4; - -import java.util.concurrent.Executors; - -import io.netty.channel.socket.nio.BossPool; -import io.netty.channel.socket.nio.NioClientBossPool; -import io.netty.util.Timer; - -/** - * A builder to create Netty {@link io.netty.channel.socket.nio.BossPool} which can be used for sharing boos pools - * with multiple Netty {@link NettyServerBootstrapFactory} server bootstrap configurations. - */ -public final class NettyClientBossPoolBuilder { - - private String name = "NettyClientBoss"; - private String pattern; - private int bossCount = 1; - private Timer timer; - - public void setName(String name) { - this.name = name; - } - - public void setPattern(String pattern) { - this.pattern = pattern; - } - - public void setBossCount(int bossCount) { - this.bossCount = bossCount; - } - - public void setTimer(Timer timer) { - this.timer = timer; - } - - public NettyClientBossPoolBuilder withName(String name) { - setName(name); - return this; - } - - public NettyClientBossPoolBuilder withPattern(String pattern) { - setPattern(pattern); - return this; - } - - public NettyClientBossPoolBuilder withBossCount(int bossCount) { - setBossCount(bossCount); - return this; - } - - public NettyClientBossPoolBuilder withTimer(Timer timer) { - setTimer(timer); - return this; - } - - /** - * Creates a new boss pool. - */ - BossPool build() { - return new NioClientBossPool(Executors.newCachedThreadPool(), bossCount, timer, new CamelNettyThreadNameDeterminer(pattern, name)); - } -}
