00001 /* 00002 * Copyright (C) 2011 Google Inc. 00003 * 00004 * Licensed under the Apache License, Version 2.0 (the "License"); you may not 00005 * use this file except in compliance with the License. You may obtain a copy of 00006 * the License at 00007 * 00008 * http://www.apache.org/licenses/LICENSE-2.0 00009 * 00010 * Unless required by applicable law or agreed to in writing, software 00011 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT 00012 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the 00013 * License for the specific language governing permissions and limitations under 00014 * the License. 00015 */ 00016 00017 package org.ros.internal.transport.tcp; 00018 00019 import static org.jboss.netty.channel.Channels.pipeline; 00020 00021 import org.jboss.netty.channel.ChannelPipeline; 00022 import org.jboss.netty.channel.ChannelPipelineFactory; 00023 import org.jboss.netty.channel.group.ChannelGroup; 00024 import org.ros.internal.transport.ConnectionTrackingHandler; 00025 00029 public class ConnectionTrackingChannelPipelineFactory implements ChannelPipelineFactory { 00030 00031 public static final String CONNECTION_TRACKING_HANDLER = "ConnectionTrackingHandler"; 00032 00033 private final ConnectionTrackingHandler connectionTrackingHandler; 00034 00035 public ConnectionTrackingChannelPipelineFactory(ChannelGroup channelGroup){ 00036 this.connectionTrackingHandler = new ConnectionTrackingHandler(channelGroup); 00037 } 00038 00039 @Override 00040 public ChannelPipeline getPipeline() { 00041 ChannelPipeline pipeline = pipeline(); 00042 pipeline.addLast(CONNECTION_TRACKING_HANDLER, connectionTrackingHandler); 00043 return pipeline; 00044 } 00045 }