0
public void configure() throws Exception {
KeyStoreParameters ksp = new KeyStoreParameters();
ksp.setResource(getConfigDir() + keystore);
ksp.setPassword("changeit");
TrustManagersParameters tmp = new TrustManagersParameters();
tmp.setKeyStore(ksp);
SSLContextParameters scp = new SSLContextParameters();
scp.setTrustManagers(tmp);
HttpComponent httpComponent = getContext().getComponent("https4", HttpComponent.class);
httpComponent.setSslContextParameters(scp);
from("timer://timer1?fixedRate=true&period=5000")
.setHeader(Exchange.HTTP_METHOD, constant(HttpMethods.GET))
.to(getSource())
.log(LoggingLevel.INFO, "File ${file:name} inProgress")
.to(getDestination()).process(new Processor() {
public void process(Exchange exchange) throws Exception {
String currentFileName = (String) exchange.getIn().getHeader(Exchange.FILE_NAME);
Long currentFileSize = (Long) exchange.getIn().getHeader(Exchange.FILE_LENGTH);
feedLogger.log(Level.INFO, currentFileName + " processed");
feedLogger.log(Level.INFO, currentFileName + " size: " + currentFileSize + " Bytes");
}
}).log(LoggingLevel.INFO, "File ${file:name} processed").setId(getId());
}
私のソースへの有効な証明書パスを見つけることがSTILなかったSSLContextを使用するためのコンポーネントの構成は、HTTPSを言うことができますHTTPS4:https://www.blabla.orgを、私は** componenetとしてHTTP4を使用して、それでも私を与えますよ。 **は、キーストアファイルを要求されたターゲット