</BUG>
return new ChannelPipelineFactory() {
@Override
public ChannelPipeline getPipeline() throws Exception {
<BUG>ChannelPipeline p = Channels.pipeline();

for (Pair<String, ? extends ChannelHandler> pair : handlerList) {
p.addLast(pair.first(), pair.second());
}</BUG>
return p;

? configuration.getInt(CK_RECV_BUFFER_SIZE)
: MessageInput.getDefaultRecvBufferSize();
this.localRegistry = localRegistry;
localRegistry.registerAll(MetricSets.of(throughputCounter.gauges()));
}
private ChannelPipelineFactory getPipelineFactory(final LinkedHashMap<String, Callable<? extends ChannelHandler>> handlerList) {
return new ChannelPipelineFactory() {
@Override
public ChannelPipeline getPipeline() throws Exception {
final ChannelPipeline p = Channels.pipeline();
for (final Map.Entry<String, Callable<? extends ChannelHandler>> entry : handlerList.entrySet()) {
p.addLast(entry.getKey(), entry.getValue().call());
