Apache Camel + JBoss Fuse - Маршрутизация между компонентом CXFRS и компонентом bean - поток IOException закрыт

Похоже, ваш звонок не был принят из-за отражения класса обслуживания. Я не совсем уверен, что пытается сделать ваш класс преобразования, но пробовали ли вы просто добавить поставщика в конец вашего клиента / сервера для обработки сопоставления Json с POJO? Позвольте мне опубликовать простой пример, который сработал для меня (я сделал это в blueprint, но он должен работать аналогично для DSL). Извините за состояние кода, я все еще много тестирую, чтобы найти, что работает, а что нет.

Здесь у меня есть и клиент, и сервер cxf rs:

<cxf:rsClient id="rsClient" address="${CXFclient}" serviceClass="com.limelight.esb.servicedb.services.ServiceDBExternalRestService"
    loggingFeatureEnabled="true" loggingSizeLimit="500">
    <cxf:providers>
        <bean class="com.fasterxml.jackson.jaxrs.json.JacksonJsonProvider" />
    </cxf:providers>
</cxf:rsClient>

<cxf:rsServer id="rsServer" address="${CXFserver}${serverService}" serviceClass="com.limelight.esb.servicedb.services.ServiceDBRestService"
    loggingFeatureEnabled="true" loggingSizeLimit="500">
    <cxf:providers>
        <bean class="com.fasterxml.jackson.jaxrs.json.JacksonJsonProvider" />
    </cxf:providers>
</cxf:rsServer>

Мой маршрут выглядит следующим образом:

    <route id="servicedb.rest.company.get.route">
        <from uri="{{servicedb.rest.company.get}}" />
        <log message="Rest getCompany called." />
        <to uri="{{servicedb.company.get}}" />
        <removeHeader headerName="Content-Length" />
    </route>

И, наконец, мой класс обслуживания:

@Path("/servicedb/")
public class ServiceDBRestService {
    @GET
    @Path("company/{id}")
    @Produces("application/json")
    public ServiceDBCompanyResponse getCompanyRest(@PathParam("id") String id) {
        //just an interface
        return null;
    }
}

Это также может быть связано с заголовком ожидаемого объекта ответа. Для этого вы можете использовать собственный препроцессор, чтобы изменить это и просто добавить его в маршрут, прежде чем вы сделаете вызов.

public class ServiceDBProcessors implements Processor {

@Override
public void process(Exchange exchng) throws Exception {        
    exchng.getIn().setHeader("CamelCxfRsResponseClass", your.class.here.class);
}

} Причина, по которой я наткнулся на этот элемент, заключается в том, что я столкнулся с этой проблемой при вызове через мыло, с которой мне пришлось немного поиграть, пока я не нашел здесь ваше решение. Если приведенное выше не помогает, я могу по крайней мере дать немного лучший ответ, который устраняет часть преобразования. Я обнаружил, что вы можете поместить другой обработчик после возврата, чтобы выполнить преобразование, и его следует подбирать с отражением, если ваш входной параметр является строкой. Мне пришлось написать такой класс:

    public ServiceDBCompany convertCompany(String companyResponseBody) {
        ServiceDBCompany newCompany = new ServiceDBCompany();
        if(companyResponseBody!=null && companyResponseBody.length()>0){
            ObjectMapper mapper = new ObjectMapper();
            try {
                ServiceDBCompanyResponse company = mapper.readValue(companyResponseBody, ServiceDBCompanyResponse.class);
                newCompany.setCompanyId(company.getCompanyId());
                newCompany.setName(company.getCompanyName());
            } catch(IOException e) {
                System.out.println("Exception reading body, returning null " + ServiceDBCompany.class);
            }
        }
        return newCompany;
}

Надеюсь, это даст вам хотя бы несколько идей о решениях, которые вы можете попробовать!