SSL-сокет Spring Integration

Question

Я могу создать сокет-соединение SSL и получать сообщения с помощью автономной программы

           SSLSocket ssl_socket;
            ssl_socket = (SSLSocket) SSLSocketFactory.getDefault().createSocket(machineName, port);
            // enable certifcate validation:
            SSLParameters sslParams = new SSLParameters();
            sslParams.setEndpointIdentificationAlgorithm("HTTPS");
            ssl_socket.setSSLParameters(sslParams);
            initiation_command += "\n";

            //send your initiation command
            OutputStreamWriter writer = new OutputStreamWriter(ssl_socket.getOutputStream(), "UTF8");
            writer.write(initiation_command);
            writer.flush();
            InputStream inputStream = ssl_socket.getInputStream();
            // read messages
            BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));

Я хочу использовать Spring Integration java DSL для

1. Открыть Соединение через сокет SSL, как показано выше
2. Получение сообщений
3. Повторное подключение в случае потери соединения

Не могли бы вы сообщить, как этого можно добиться с помощью Spring Integration на основе на приведенный выше автономный код?