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[]bucketsToBeRemovedprotected java.lang.Throwableexceptionprotected com.amazonaws.services.s3.AmazonS3s3clientprotected 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 voidfinishUp()XThreadBuffer<S3Artifact>getBuffer()voidrun()voidsetBuffer(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:
runin interfacejava.lang.Runnable- Overrides:
runin classjava.lang.Thread
-
finishUp
public void finishUp() throws java.lang.InterruptedException, java.io.IOException, ResponseException- Throws:
java.lang.InterruptedExceptionjava.io.IOExceptionResponseException
-
-