如何设置Camel RESTful客户端超时和HTTPClientPolicy

Question

我们能以编程方式获取HTTPClientPolicy对象吗？或者我们必须在传递给template.send（）的Camel URI中引用它，例如：

template.send（“cxfrs：//”+url+“/match/”+appId+“/”+reqid？httpclientapi=true&http.connection.timeout=5000

Answer 1

如果您想用XML文件配置endpoint超时，那么Raphaëλ之前发布的链接是正确的。但是，如果您希望完全以编程方式完成，可以使用cxf组件的一个选项（cxfEndpointConfigurer）来完成，如camel-cxf组件单元测试所示。

在您的情况下，它是这样的：

template.send("cxfrs://" + url + "/match/" + appId + "/" + "reqId?httpClientAPI=true&cxfEndpointConfigurer=#endpointConfigurer"

然后您将需要一个具有如下配置的“EndpointConfigurer”bean：

@Component("endpointConfigurer")
public class TemplateEndpointConfigurer implements CxfEndpointConfigurer {

    @Override
    public void configure(AbstractWSDLBasedEndpointFactory factoryBean) {
        // Do nothing here
    }

    @Override
    public void configureClient(Client client) {

        final HTTPConduit conduit = (HTTPConduit) client.getConduit();

        final HTTPClientPolicy policy = new HTTPClientPolicy();
        policy.setConnectionTimeout(webServiceConnectionTimeout);
        policy.setReceiveTimeout(webServiceReadTimeout);
        policy.setConnection(ConnectionType.CLOSE);
        conduit.setClient(policy);

    }

    @Override
    public void configureServer(Server server) {
        // Do nothing here
    }
}