public class ReportQueueManager extends MaximoThread
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MAX_CONCURRENT_THREADCOUNT |
static int |
DEFAULT_QUEUE_IDLETIME_SECONDS |
static java.lang.String |
PROPERTY_DISABLEQUEUEMANAGER |
static java.lang.String |
PROPERTY_MAXCONCURRENTRUN |
static java.lang.String |
PROPERTY_QUEUEIDLETIMESECONDS |
Constructor and Description |
---|
ReportQueueManager() |
Modifier and Type | Method and Description |
---|---|
boolean |
acquireLock(long runQueueId)
Aquires lock on a report that can be run, so that the report is run by
only one thread.
|
void |
createFileFromStream(java.io.File file,
java.io.InputStream inputStream) |
int |
getMaxAllowedActiveReportThreads() |
int |
getQueueIdleTime() |
void |
removeRunReport(long runQueueId) |
void |
run() |
isMarkedForShutDown, markShutdown
activeCount, checkAccess, 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
public static final int DEFAULT_QUEUE_IDLETIME_SECONDS
public static final java.lang.String PROPERTY_QUEUEIDLETIMESECONDS
public static final java.lang.String PROPERTY_DISABLEQUEUEMANAGER
public static final int DEFAULT_MAX_CONCURRENT_THREADCOUNT
public static final java.lang.String PROPERTY_MAXCONCURRENTRUN
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public boolean acquireLock(long runQueueId)
runQueueId
- public void removeRunReport(long runQueueId)
public int getMaxAllowedActiveReportThreads()
public int getQueueIdleTime()
public void createFileFromStream(java.io.File file, java.io.InputStream inputStream) throws java.io.IOException
java.io.IOException