Class AmazonS3Connector.GetSeedsThread
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.manifoldcf.crawler.connectors.amazons3.AmazonS3Connector.GetSeedsThread
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- AmazonS3Connector
protected static class AmazonS3Connector.GetSeedsThread extends java.lang.Thread
-
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.String[]
bucketsToBeRemoved
protected java.lang.Throwable
exception
protected com.amazonaws.services.s3.AmazonS3
s3client
protected XThreadBuffer<S3Artifact>
seedBuffer
-
Constructor Summary
Constructors Constructor Description GetSeedsThread(com.amazonaws.services.s3.AmazonS3 s3, java.lang.String[] buckets)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
finishUp()
XThreadBuffer<S3Artifact>
getBuffer()
void
run()
void
setBuffer(XThreadBuffer<S3Artifact> buffer)
-
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
-
exception
protected java.lang.Throwable exception
-
bucketsToBeRemoved
protected java.lang.String[] bucketsToBeRemoved
-
s3client
protected com.amazonaws.services.s3.AmazonS3 s3client
-
seedBuffer
protected XThreadBuffer<S3Artifact> seedBuffer
-
-
Method Detail
-
getBuffer
public XThreadBuffer<S3Artifact> getBuffer()
-
setBuffer
public void setBuffer(XThreadBuffer<S3Artifact> buffer)
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
finishUp
public void finishUp() throws java.lang.InterruptedException, java.io.IOException, ResponseException
- Throws:
java.lang.InterruptedException
java.io.IOException
ResponseException
-
-