Class ServiceUnavailableAsyncDecorator
java.lang.Object
org.apache.hc.client5.testing.async.ServiceUnavailableAsyncDecorator
- All Implemented Interfaces:
org.apache.hc.core5.http.nio.AsyncDataConsumer
,org.apache.hc.core5.http.nio.AsyncDataExchangeHandler
,org.apache.hc.core5.http.nio.AsyncDataProducer
,org.apache.hc.core5.http.nio.AsyncServerExchangeHandler
,org.apache.hc.core5.http.nio.ResourceHolder
public class ServiceUnavailableAsyncDecorator
extends Object
implements org.apache.hc.core5.http.nio.AsyncServerExchangeHandler
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final org.apache.hc.core5.http.nio.AsyncServerExchangeHandler
private final org.apache.hc.core5.function.Resolver
<org.apache.hc.core5.http.HttpRequest, org.apache.hc.core5.util.TimeValue> private final AtomicBoolean
-
Constructor Summary
ConstructorsConstructorDescriptionServiceUnavailableAsyncDecorator
(org.apache.hc.core5.http.nio.AsyncServerExchangeHandler exchangeHandler, org.apache.hc.core5.function.Resolver<org.apache.hc.core5.http.HttpRequest, org.apache.hc.core5.util.TimeValue> serviceAvailabilityResolver) -
Method Summary
Modifier and TypeMethodDescriptionint
final void
consume
(ByteBuffer src) void
void
handleRequest
(org.apache.hc.core5.http.HttpRequest request, org.apache.hc.core5.http.EntityDetails entityDetails, org.apache.hc.core5.http.nio.ResponseChannel responseChannel, org.apache.hc.core5.http.protocol.HttpContext context) void
produce
(org.apache.hc.core5.http.nio.DataStreamChannel channel) void
final void
final void
updateCapacity
(org.apache.hc.core5.http.nio.CapacityChannel capacityChannel)
-
Field Details
-
exchangeHandler
private final org.apache.hc.core5.http.nio.AsyncServerExchangeHandler exchangeHandler -
serviceAvailabilityResolver
private final org.apache.hc.core5.function.Resolver<org.apache.hc.core5.http.HttpRequest,org.apache.hc.core5.util.TimeValue> serviceAvailabilityResolver
-
-
Constructor Details
-
ServiceUnavailableAsyncDecorator
public ServiceUnavailableAsyncDecorator(org.apache.hc.core5.http.nio.AsyncServerExchangeHandler exchangeHandler, org.apache.hc.core5.function.Resolver<org.apache.hc.core5.http.HttpRequest, org.apache.hc.core5.util.TimeValue> serviceAvailabilityResolver)
-
-
Method Details
-
handleRequest
public void handleRequest(org.apache.hc.core5.http.HttpRequest request, org.apache.hc.core5.http.EntityDetails entityDetails, org.apache.hc.core5.http.nio.ResponseChannel responseChannel, org.apache.hc.core5.http.protocol.HttpContext context) throws org.apache.hc.core5.http.HttpException, IOException - Specified by:
handleRequest
in interfaceorg.apache.hc.core5.http.nio.AsyncServerExchangeHandler
- Throws:
org.apache.hc.core5.http.HttpException
IOException
-
updateCapacity
public final void updateCapacity(org.apache.hc.core5.http.nio.CapacityChannel capacityChannel) throws IOException - Specified by:
updateCapacity
in interfaceorg.apache.hc.core5.http.nio.AsyncDataConsumer
- Throws:
IOException
-
consume
- Specified by:
consume
in interfaceorg.apache.hc.core5.http.nio.AsyncDataConsumer
- Throws:
IOException
-
streamEnd
public final void streamEnd(List<? extends org.apache.hc.core5.http.Header> trailers) throws org.apache.hc.core5.http.HttpException, IOException - Specified by:
streamEnd
in interfaceorg.apache.hc.core5.http.nio.AsyncDataConsumer
- Throws:
org.apache.hc.core5.http.HttpException
IOException
-
available
public int available()- Specified by:
available
in interfaceorg.apache.hc.core5.http.nio.AsyncDataProducer
-
produce
- Specified by:
produce
in interfaceorg.apache.hc.core5.http.nio.AsyncDataProducer
- Throws:
IOException
-
failed
- Specified by:
failed
in interfaceorg.apache.hc.core5.http.nio.AsyncDataExchangeHandler
-
releaseResources
public void releaseResources()- Specified by:
releaseResources
in interfaceorg.apache.hc.core5.http.nio.ResourceHolder
-