用Camel的ProducerTemplate#sendBody()发送POJO需要什么

org.apache.camel.language.bean.RuntimeBeanExpressionException: Failed to invoke 
  method: [searchId] on app.FsiRequest due to: 
  java.lang.IndexOutOfBoundsException: Key: searchId not found in bean: 
  app.FsiRequest@5c2d65cf of type: app.FsiRequest using OGNL path [[searchId]]

    at org.apache.camel.language.bean.BeanExpression.evaluate(BeanExpression.java:119) ~[camel-core-2.22.1.jar:2.22.1]
    at org.apache.camel.language.bean.BeanExpression.evaluate(BeanExpression.java:135) ~[camel-core-2.22.1.jar:2.22.1]
    at org.apache.camel.model.language.ExpressionDefinition.evaluate(ExpressionDefinition.java:127) ~[camel-core-2.22.1.jar:2.22.1]
    at org.apache.camel.model.language.ExpressionDefinition.evaluate(ExpressionDefinition.java:119) ~[camel-core-2.22.1.jar:2.22.1]
    at org.apache.camel.builder.ExpressionBuilder$40.evaluate(ExpressionBuilder.java:1004) ~[camel-core-2.22.1.jar:2.22.1]
    at org.apache.camel.support.ExpressionAdapter.evaluate(ExpressionAdapter.java:36) ~[camel-core-2.22.1.jar:2.22.1]
    at org.apache.camel.builder.SimpleBuilder.evaluate(SimpleBuilder.java:92) ~[camel-core-2.22.1.jar:2.22.1]

我要发送的类(简化):

public class FsiRequest {
    public String getSearchId() {
        return searchId;
    }

    public void setSearchId(String searchId) {
        this.searchId = searchId;
    }

    private String searchId;

    public FsiRequest(Map<String, String> request) {
        searchId = request.get("searchId");
    }
}

以下是我的祈祷:

private final ForkJoinPool routeExecutorPool = new ForkJoinPool(1024);

@Override
public void configure() {
    from("servlet://" + SEARCH_REQUEST)
            .process(exchange -> {
                FsiRequest request = createRequestMap(exchange);
                sendRequestToAllProviderRoutes(exchange, request);
            })
            .transform()
            .constant("OK");
}

private void sendRequestToAllProviderRoutes(Exchange exchange, FsiRequest request) {
    try {
        ProducerTemplate tmpl = exchange.getContext().createProducerTemplate();
        routeExecutorPool.execute(() -> getRoutes(exchange).parallelStream().forEach(
                route -> tmpl.sendBody(route, request)
        ));
    } catch (RejectedExecutionException | RuntimeCamelException e) {
        log.error("FSI Servlet failed to send request to provider routes", e);
    }
}

getRoutes() 通过筛选获取相关路由 exchange.getContext().getRouteDefinitions()

sendBody() 当我使用 HashMap<String, Object> 而不是FsiRequest类。