in components/camel-cxf/camel-cxf-all/src/main/java/org/apache/camel/component/cxf/transport/http/osgi/HttpConduitConfigApplier.java [318:363]
private void applyClientPolicies(Dictionary<String, String> d, HTTPConduit c) {
Enumeration<String> keys = d.keys();
HTTPClientPolicy p = c.getClient();
while (keys.hasMoreElements()) {
String k = keys.nextElement();
if (k.startsWith("client.")) {
if (p == null) {
p = new HTTPClientPolicy();
c.setClient(p);
}
String v = d.get(k);
k = k.substring("client.".length());
if ("ConnectionTimeout".equals(k)) {
p.setConnectionTimeout(Long.parseLong(v.trim()));
} else if ("ReceiveTimeout".equals(k)) {
p.setReceiveTimeout(Long.parseLong(v.trim()));
} else if ("AsyncExecuteTimeout".equals(k)) {
p.setAsyncExecuteTimeout(Long.parseLong(v.trim()));
} else if ("AsyncExecuteTimeoutRejection".equals(k)) {
p.setAsyncExecuteTimeoutRejection(Boolean.parseBoolean(v.trim()));
} else if ("AutoRedirect".equals(k)) {
p.setAutoRedirect(Boolean.parseBoolean(v.trim()));
} else if ("MaxRetransmits".equals(k)) {
p.setMaxRetransmits(Integer.parseInt(v.trim()));
} else if ("AllowChunking".equals(k)) {
p.setAllowChunking(Boolean.parseBoolean(v.trim()));
} else if ("ChunkingThreshold".equals(k)) {
p.setChunkingThreshold(Integer.parseInt(v.trim()));
} else if ("ChunkLength".equals(k)) {
p.setChunkLength(Integer.parseInt(v.trim()));
} else if ("Connection".equals(k)) {
p.setConnection(ConnectionType.valueOf(v));
} else if ("DecoupledEndpoint".equals(k)) {
p.setDecoupledEndpoint(v);
} else if ("ProxyServer".equals(k)) {
p.setProxyServer(v);
} else if ("ProxyServerPort".equals(k)) {
p.setProxyServerPort(Integer.parseInt(v.trim()));
} else if ("ProxyServerType".equals(k)) {
p.setProxyServerType(ProxyServerType.fromValue(v));
} else if ("NonProxyHosts".equals(k)) {
p.setNonProxyHosts(v);
}
}
}
}