if (!TCPConstants.PROTOCOL_SCHEMA.equalsIgnoreCase(context.getAddress().getURI().getScheme())) {
return null;
}
if (context.getService().getServiceName().equals(serviceChannelServiceName)) {
return new ServiceChannelTransportPipe(context);
}
return new TCPTransportPipe(context);