protected static class ThrottledFetcher.ExecuteMethodThread extends Thread
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
protected boolean |
abortThread |
protected InputStream |
bodyStream |
protected org.apache.http.client.methods.HttpRequestBase |
executeMethod |
protected IFetchThrottler |
fetchThrottler
The fetch throttler
|
protected Throwable |
generalException |
protected org.apache.http.client.HttpClient |
httpClient
Client and method, all preconfigured
|
protected org.apache.http.HttpResponse |
response |
protected Throwable |
responseException |
protected Throwable |
shutdownException |
protected boolean |
streamCreated |
protected Throwable |
streamException |
protected ThrottledFetcher.ThrottledConnection |
theConnection
The connection
|
protected XThreadInputStream |
threadStream |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
ThrottledFetcher.ExecuteMethodThread(ThrottledFetcher.ThrottledConnection theConnection,
IFetchThrottler fetchThrottler,
org.apache.http.client.HttpClient httpClient,
org.apache.http.client.methods.HttpRequestBase executeMethod) |
Modifier and Type | Method and Description |
---|---|
void |
abort() |
protected void |
checkException(Throwable exception) |
void |
finishUp() |
String |
getFirstHeader(String headerName) |
int |
getResponseCode() |
InputStream |
getSafeInputStream() |
void |
run() |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
protected final ThrottledFetcher.ThrottledConnection theConnection
protected final IFetchThrottler fetchThrottler
protected final org.apache.http.client.HttpClient httpClient
protected final org.apache.http.client.methods.HttpRequestBase executeMethod
protected org.apache.http.HttpResponse response
protected Throwable responseException
protected XThreadInputStream threadStream
protected InputStream bodyStream
protected boolean streamCreated
protected Throwable streamException
protected boolean abortThread
protected Throwable shutdownException
protected Throwable generalException
public ThrottledFetcher.ExecuteMethodThread(ThrottledFetcher.ThrottledConnection theConnection, IFetchThrottler fetchThrottler, org.apache.http.client.HttpClient httpClient, org.apache.http.client.methods.HttpRequestBase executeMethod)
public int getResponseCode() throws InterruptedException, IOException, org.apache.http.HttpException
InterruptedException
IOException
org.apache.http.HttpException
public String getFirstHeader(String headerName) throws InterruptedException, IOException, org.apache.http.HttpException
InterruptedException
IOException
org.apache.http.HttpException
public InputStream getSafeInputStream() throws InterruptedException, IOException, org.apache.http.HttpException
InterruptedException
IOException
org.apache.http.HttpException
public void abort()
public void finishUp() throws InterruptedException
InterruptedException
protected void checkException(Throwable exception) throws IOException, org.apache.http.HttpException
IOException
org.apache.http.HttpException