public class BasicRequestProducer extends Object implements AsyncRequestProducer
AsyncRequestProducer
that produces one fixed request
and relies on a AsyncEntityProducer
to generate request entity stream.Constructor and Description |
---|
BasicRequestProducer(HttpRequest request,
AsyncEntityProducer dataProducer) |
BasicRequestProducer(Method method,
HttpHost host,
String path) |
BasicRequestProducer(Method method,
HttpHost host,
String path,
AsyncEntityProducer dataProducer) |
BasicRequestProducer(Method method,
URI requestUri) |
BasicRequestProducer(Method method,
URI requestUri,
AsyncEntityProducer dataProducer) |
BasicRequestProducer(String method,
HttpHost host,
String path) |
BasicRequestProducer(String method,
HttpHost host,
String path,
AsyncEntityProducer dataProducer) |
BasicRequestProducer(String method,
URI requestUri) |
BasicRequestProducer(String method,
URI requestUri,
AsyncEntityProducer dataProducer) |
Modifier and Type | Method and Description |
---|---|
int |
available()
Returns the number of bytes immediately available for output.
|
void |
failed(Exception cause)
Triggered to signal a failure in data generation.
|
boolean |
isRepeatable()
Determines whether the producer can consistently produce the same content
after invocation of
ResourceHolder.releaseResources() . |
void |
produce(DataStreamChannel channel)
Triggered to signal the ability of the underlying data channel
to accept more data.
|
void |
releaseResources() |
void |
sendRequest(RequestChannel requestChannel,
HttpContext httpContext)
Triggered to signal the ability of the underlying request channel
to accept a request messages.
|
public BasicRequestProducer(HttpRequest request, AsyncEntityProducer dataProducer)
public BasicRequestProducer(String method, HttpHost host, String path, AsyncEntityProducer dataProducer)
public BasicRequestProducer(String method, URI requestUri, AsyncEntityProducer dataProducer)
public BasicRequestProducer(Method method, HttpHost host, String path, AsyncEntityProducer dataProducer)
public BasicRequestProducer(Method method, URI requestUri, AsyncEntityProducer dataProducer)
public void sendRequest(RequestChannel requestChannel, HttpContext httpContext) throws HttpException, IOException
AsyncRequestProducer
sendRequest
in interface AsyncRequestProducer
requestChannel
- the request channel capable to accepting a request message.httpContext
- the actual execution context.HttpException
IOException
public int available()
AsyncDataProducer
available
in interface AsyncDataProducer
public void produce(DataStreamChannel channel) throws IOException
AsyncDataProducer
produce
in interface AsyncDataProducer
channel
- the data channel capable to accepting more data.IOException
public boolean isRepeatable()
AsyncRequestProducer
ResourceHolder.releaseResources()
.isRepeatable
in interface AsyncRequestProducer
public void failed(Exception cause)
AsyncRequestProducer
failed
in interface AsyncRequestProducer
cause
- the cause of the failure.public void releaseResources()
releaseResources
in interface ResourceHolder
Copyright © 2005–2021 The Apache Software Foundation. All rights reserved.