Class GenericConnector.ExecuteProcessThread
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.manifoldcf.crawler.connectors.generic.GenericConnector.ExecuteProcessThread
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- GenericConnector
protected static class GenericConnector.ExecuteProcessThread extends java.lang.Thread
-
-
Field Summary
Fields Modifier and Type Field Description protected boolean
abortThread
protected org.apache.http.client.HttpClient
client
protected java.lang.Throwable
exception
protected long
streamLength
protected org.apache.manifoldcf.connectorcommon.common.XThreadInputStream
threadStream
protected java.lang.String
url
-
Constructor Summary
Constructors Constructor Description ExecuteProcessThread(org.apache.http.client.HttpClient client, java.lang.String url)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
checkException(java.lang.Throwable exception)
void
finishUp()
java.lang.Throwable
getException()
java.io.InputStream
getSafeInputStream()
long
getStreamLength()
void
run()
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Field Detail
-
client
protected final org.apache.http.client.HttpClient client
-
url
protected final java.lang.String url
-
exception
protected java.lang.Throwable exception
-
threadStream
protected org.apache.manifoldcf.connectorcommon.common.XThreadInputStream threadStream
-
abortThread
protected boolean abortThread
-
streamLength
protected long streamLength
-
-
Method Detail
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
getSafeInputStream
public java.io.InputStream getSafeInputStream() throws java.lang.InterruptedException, java.io.IOException, org.apache.manifoldcf.core.interfaces.ManifoldCFException
- Throws:
java.lang.InterruptedException
java.io.IOException
org.apache.manifoldcf.core.interfaces.ManifoldCFException
-
getStreamLength
public long getStreamLength() throws java.io.IOException, java.lang.InterruptedException, org.apache.manifoldcf.core.interfaces.ManifoldCFException
- Throws:
java.io.IOException
java.lang.InterruptedException
org.apache.manifoldcf.core.interfaces.ManifoldCFException
-
checkException
protected void checkException(java.lang.Throwable exception) throws java.io.IOException, org.apache.manifoldcf.core.interfaces.ManifoldCFException
- Throws:
java.io.IOException
org.apache.manifoldcf.core.interfaces.ManifoldCFException
-
finishUp
public void finishUp() throws java.lang.InterruptedException, java.io.IOException, org.apache.manifoldcf.core.interfaces.ManifoldCFException
- Throws:
java.lang.InterruptedException
java.io.IOException
org.apache.manifoldcf.core.interfaces.ManifoldCFException
-
getException
public java.lang.Throwable getException()
-
-