docs: private KubernetesCommand<?> getCommand(Message message, KubernetesEndpointConfiguration endpointConfiguration) {
          Object payload = message.getPayload();
  
          KubernetesCommand<?> command;
          if (message instanceof KubernetesMessage) {
              command = createCommandFromRequest(message.getPayload(KubernetesRequest.class));
          } else if (message.getHeaders().containsKey(KubernetesMessageHeaders.COMMAND) &&
                  (payload == null || !StringUtils.hasText(payload.toString()))) {
              command = getCommandByName(message.getHeader(KubernetesMessageHeaders.COMMAND).toString());
          } else if (payload instanceof KubernetesCommand) {
              command = (KubernetesCommand) payload;
          } else {
              try {
                  KubernetesRequest request = endpointConfiguration.getObjectMapper()
                          .readValue(message.getPayload(String.class), KubernetesRequest.class);
                  command = createCommandFromRequest(request);
              } catch (IOException e) {
                  throw new CitrusRuntimeException("Failed to read kubernetes request from payload", e);
              }
          }
  
          if (command == null) {
              throw new CitrusRuntimeException("Unable to create proper Kubernetes command from payload: " + payload);
          }
  
          return command;
      }