gistfile1.txt

        IntegrationFlow privateFeedFlow = f -> f.handle(Tcp
                .outboundGateway(
                        Tcp.netClient(privateFeed.getHostname(), (int) privateFeed.getPort())
                                .serializer(TcpCodecs.crlf())
                                .deserializer(TcpCodecs.lengthHeader1())
                                .id("privateFeed"))
                .remoteTimeout(m -> 5000))
                .transform(Transformers.objectToString())
                .handle(System.out::println);