public final class TimeoutHttpRequesterFilter extends java.lang.Object implements StreamingHttpClientFilterFactory, StreamingHttpConnectionFilterFactory, HttpExecutionStrategyInfluencer
Constructor and Description |
---|
TimeoutHttpRequesterFilter(java.time.Duration duration)
Creates a new instance.
|
TimeoutHttpRequesterFilter(java.time.Duration duration,
Executor timeoutExecutor)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
StreamingHttpClientFilter |
create(FilterableStreamingHttpClient client)
Creates a
StreamingHttpClientFilter using the provided StreamingHttpClientFilter . |
StreamingHttpConnectionFilter |
create(FilterableStreamingHttpConnection connection)
Create a
StreamingHttpConnectionFilter using the provided FilterableStreamingHttpConnection . |
HttpExecutionStrategy |
influenceStrategy(HttpExecutionStrategy strategy)
Optionally modify the passed
HttpExecutionStrategy to a new HttpExecutionStrategy that suits
this HttpExecutionStrategyInfluencer . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
append, asMultiAddressClientFilter
append
defaultStreamingInfluencer
public TimeoutHttpRequesterFilter(java.time.Duration duration)
duration
- the timeout Duration
public StreamingHttpClientFilter create(FilterableStreamingHttpClient client)
StreamingHttpClientFilterFactory
StreamingHttpClientFilter
using the provided StreamingHttpClientFilter
.create
in interface StreamingHttpClientFilterFactory
client
- FilterableStreamingHttpClient
to filterStreamingHttpClientFilter
using the provided StreamingHttpClientFilter
.public StreamingHttpConnectionFilter create(FilterableStreamingHttpConnection connection)
StreamingHttpConnectionFilterFactory
StreamingHttpConnectionFilter
using the provided FilterableStreamingHttpConnection
.create
in interface StreamingHttpConnectionFilterFactory
connection
- FilterableStreamingHttpConnection
to filterStreamingHttpConnectionFilter
using the provided FilterableStreamingHttpConnection
.public HttpExecutionStrategy influenceStrategy(HttpExecutionStrategy strategy)
HttpExecutionStrategyInfluencer
HttpExecutionStrategy
to a new HttpExecutionStrategy
that suits
this HttpExecutionStrategyInfluencer
.influenceStrategy
in interface HttpExecutionStrategyInfluencer
strategy
- HttpExecutionStrategy
to influence.HttpExecutionStrategy
that suits this HttpExecutionStrategyInfluencer