Отправка данных на внешний ресурс: почему содержимое имеет значение null?

Question

У меня есть простой верблюжий маршрут. Я хочу извлечь файл из очереди и передать его с помощью запроса POST на внешний ресурс. Этот маршрут работает, и запрос достигает внешнего ресурса:

import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;

public class MyRouteBuilder extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        from("activemq:alfresco-queue")
        .process(new Processor() {
            public void process(Exchange exchange) throws Exception {
                byte[] bytes = exchange.getIn().getBody(byte[].class);

                // All of that not working...
                // exchange.getIn().setHeader("content", bytes); gives "java.lang.IllegalAgrumentException: Request header is too large"
                // exchange.getIn().setBody(bytes, byte[].class); gives "size of content is -1"
                // exchange.getIn().setBody(bytes); gives "size of content is -1"
                // ???

                // ??? But I can print file content here
                for(int i=0; i < bytes.length; i++) {
                    System.out.print((char) bytes[i]);
                }
            }
        })

        .setHeader(Exchange.HTTP_METHOD, constant("POST"))
        .setHeader(Exchange.CONTENT_TYPE, constant("multipart/form-data"))
        .to("http://vm-alfce52-31......com:8080/alfresco/s/someco/queuefileuploader?guest=true")

        .process(new Processor() {
            public void process(Exchange exchange) throws Exception {
                System.out.println("The response code is: " + exchange.getIn().getHeader(Exchange.HTTP_RESPONSE_CODE));
            }
        });
    }
}

Вопрос в том, что полезная нагрузка запроса потеряна:

// somewhere on an external resource
Content content = request.getContent();
long len = content.getSize() // is always == -1.

// the file name is passed successfully
String fileName = request.getHeader("fileName");

Как установить и передать полезную нагрузку POST-запроса на этом маршруте / процессоре?

Я заметил, что ЛЮБЫЕ данные, установленные этим способом, также теряются. Только заголовки отправляются на удаленный ресурс.

Используя простую форму HTML с <input type="file"> закодировано в multipart/form-data Я могу успешно отправить все данные на внешний ресурс.

Что может быть причиной?

Буду очень признателен за информацию.

Спасибо всем.

---

Обновлено.

Следующий код также дает нулевой контент:

MultipartEntityBuilder multipartEntityBuilder = MultipartEntityBuilder.create();
multipartEntityBuilder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);

// this also gives null-content
//multipartEntityBuilder.addBinaryBody("file", exchange.getIn().getBody(byte[].class));

multipartEntityBuilder.addPart("file", new ByteArrayBody(exchange.getIn().getBody(byte[].class), exchange.getIn().getHeader("fileName", String.class)));
exchange.getOut().setBody(multipartEntityBuilder.build().getContent());

/********** This also gives null-content *********/
StringBody username = new StringBody("username", ContentType.MULTIPART_FORM_DATA); 
StringBody password = new StringBody("password", ContentType.MULTIPART_FORM_DATA); 

MultipartEntityBuilder multipartEntityBuilder = MultipartEntityBuilder.create(); 
multipartEntityBuilder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE); 
multipartEntityBuilder.addPart("username", username); 
multipartEntityBuilder.addPart("password", password); 

String filename = (String) exchange.getIn().getHeader("fileName");

File file = new File(filename);
try(RandomAccessFile accessFile = new RandomAccessFile(file, "rw")) {
    accessFile.write(bytes);
}

multipartEntityBuilder.addPart("upload", new FileBody(file, ContentType.MULTIPART_FORM_DATA, filename));
exchange.getIn().setBody(multipartEntityBuilder.build().getContent());

Еще одна деталь. Если я изменю это:

exchange.getOut().setBody(multipartEntityBuilder.build().getContent());

К этому:

exchange.getOut().setBody(multipartEntityBuilder.build());

Я получаю следующее исключение на стороне FUSE (я вижу это через консоль управления hawtio):

Execution of JMS message listener failed.
Caused by: [org.apache.camel.RuntimeCamelException - org.apache.camel.InvalidPayloadException: 
No body available of type: java.io.InputStream but has value: org.apache.http.entity.mime.MultipartFormEntity@26ee73 of type: 
org.apache.http.entity.mime.MultipartFormEntity on: JmsMessage@0x1cb83b9. 
Caused by: No type converter available to convert from type: org.apache.http.entity.mime.MultipartFormEntity to the required type: 
java.io.InputStream with value org.apache.http.entity.mime.MultipartFormEntity@26ee73. Exchange[ID-63-DP-TAV-55652-1531889677177-5-1]. Caused by: 
[org.apache.camel.NoTypeConversionAvailableException - No type converter available to convert from type: 
org.apache.http.entity.mime.MultipartFormEntity to the required type: java.io.InputStream with value org.apache.http.entity.mime.MultipartFormEntity@26ee73]]

Answer 1

Я пишу небольшое приложение сервлета и получаю содержимое в doPost(...) метод из HttpServletRequest объект.

Проблема была с WebScriptRequest объект на стороне внешней системы (Alfresco).

Bedla, спасибо за советы!

---

Со стороны Alfresco проблема может быть решена следующим образом:

public class QueueFileUploader extends DeclarativeWebScript {
    protected Map<String, Object> executeImpl(WebScriptRequest req, Status status) {
        HttpServletRequest httpServletRequest = WebScriptServletRuntime.getHttpServletRequest(req);
        //  calling methods of httpServletRequest object and retrieving the content
        ...

Маршрут:

public class MyRouteBuilder extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        from("activemq:alfresco-queue")
        .process(new Processor() {
            public void process(Exchange exchange) throws Exception {
                MultipartEntityBuilder multipartEntityBuilder = MultipartEntityBuilder.create();
                multipartEntityBuilder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);
                multipartEntityBuilder.addPart("file", new ByteArrayBody(exchange.getIn().getBody(byte[].class), 
                        exchange.getIn().getHeader("fileName", String.class)));
                exchange.getIn().setBody(multipartEntityBuilder.build().getContent());              
            }
        })

        .setHeader(Exchange.HTTP_METHOD, constant(org.apache.camel.component.http4.HttpMethods.POST))
        .to("http4://localhost:8080/alfresco/s/someco/queuefileuploader?guest=true")
//      .to("http4://localhost:8080/ServletApp/hello")

        .process(new Processor() {
            public void process(Exchange exchange) throws Exception {
                System.out.println("The response code is: " + 
                        exchange.getIn().getHeader(Exchange.HTTP_RESPONSE_CODE));
            }
        });
    }
}