class TcpTransport implements Transport, ConnectionObserver {

    @Override
    public void connect()
    {
        asyncTcpSocketFactory.createSocketOnOutgoingConnection(socketAddress, new SocketFactory.SocketEstablishedCallback()
        {
            @Override
            public void onSocketEstablished(final SocketChannel socketChannel)
            {
                TcpTransport.this.socketChannel = socketChannel;
                publishingTransportObserver.connectionEstablished();
            }
        });

    }

    public  TcpTransport(final PublishingConnectionObserver publishingTransportObserver, final InetSocketAddress socketAddress,
                        final SocketFactory asyncTcpSocketFactory, final TransportConfig transportConfig);

}