code: public void send(Message message, TestContext context) {
          String correlationKeyName = getEndpointConfiguration().getCorrelator().getCorrelationKeyName(getName());
          String correlationKey = getEndpointConfiguration().getCorrelator().getCorrelationKey(message);
          correlationManager.saveCorrelationKey(correlationKeyName, correlationKey, context);
  
          SshRequest request = (SshRequest) getEndpointConfiguration().getMessageConverter().convertOutbound(message, getEndpointConfiguration(), context);
  
          if (getEndpointConfiguration().isStrictHostChecking()) {
              setKnownHosts();
          }
  
          String rUser = getRemoteUser(message);
          connect(rUser);
          ChannelExec channelExec = null;
          ByteArrayOutputStream outStream = new ByteArrayOutputStream();
          ByteArrayOutputStream errStream = new ByteArrayOutputStream();
          int rc;
          try {
              channelExec = openChannelExec();
              channelExec.setErrStream(errStream);
              channelExec.setOutputStream(outStream);
              channelExec.setCommand(request.getCommand());
              doConnect(channelExec);
              if (request.getStdin() != null) {
                  sendStandardInput(channelExec, request.getStdin());
              }
              waitCommandToFinish(channelExec);
              rc = channelExec.getExitStatus();
          } finally {
              if (channelExec != null && channelExec.isConnected()) {
                  channelExec.disconnect();
              }
              disconnect();
          }
          SshResponse sshResp = new SshResponse(outStream.toString(),errStream.toString(),rc);
          Message response = getEndpointConfiguration().getMessageConverter().convertInbound(sshResp, getEndpointConfiguration(), context)
                  .setHeader("user", rUser);
  
          correlationManager.store(correlationKey, response);
      }
docs: Send a message as SSH request. The message format is created from
  {@link com.consol.citrus.ssh.server.SshServer}.
  
  @param message the message object to send.
  @param context