@Override
  public void close() throws IOException {
    try {
      if (startedSerializingMsg && !doneWritingMsg) {
        // if we wrote any bytes on the connections then we need to close them
        // since they have been corrupted by a partial serialization.
        if (flushedBytes > 0) {
          for (final Connection connection : connections) {
            connection.closeForReconnect("Message serialization could not complete");
          }
        }
      }
    } finally {
      super.close();
    }
  }
Create message streamers splitting into versioned streamers, if required, for given list of
connections to remote nodes. This method can either return a single MsgStreamer object or a
List of MsgStreamer objects.
geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamer.java