По сути, я пытаюсь создать собственный WSClient в своем приложении SBT с использованием Java. Поскольку мне не нужны никакие зависимости от внедрения, я использую метод, показанный в документация. Чтобы создать собственный WSClient, ему нужен объект Akka.stream.Materializer, но, поскольку он абстрактный, я не могу создать объект Materializer.
private Materializer materializer;
private WSClient wsClient() throws IOException {
scala.Option<String> noneString = scala.None$.empty();
WSClientConfig wsClientConfig = new WSClientConfig(
Duration.apply(120, TimeUnit.SECONDS), // connectionTimeout
Duration.apply(120, TimeUnit.SECONDS), // idleTimeout
Duration.apply(120, TimeUnit.SECONDS), // requestTimeout
true, // followRedirects
true, // useProxyProperties
noneString, // userAgent
true, // compressionEnabled / enforced
SSLConfigFactory.defaultConfig());
AhcWSClientConfig clientConfig = AhcWSClientConfigFactory.forClientConfig(wsClientConfig);
// Add underlying asynchttpclient options to WSClient
AhcConfigBuilder builder = new AhcConfigBuilder(clientConfig);
DefaultAsyncHttpClientConfig.Builder ahcBuilder = builder.configure();
AsyncHttpClientConfig.AdditionalChannelInitializer logging = new AsyncHttpClientConfig.AdditionalChannelInitializer() {
@Override
public void initChannel(io.netty.channel.Channel channel) throws Exception {
}
};
ahcBuilder.setHttpAdditionalChannelInitializer(logging);
// #ws-custom-client
WSClient customWSClient = new play.libs.ws.ahc.AhcWSClient(ahcBuilder.build(), materializer);
// #ws-client
// #ws-close-client
customWSClient.close();
return customWSClient;
}
Примечание. Я не хочу использовать внедрение зависимостей
Как мне поступить с этим?
