|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
org.edg.info.ArchiverInstance.ArchiverThread
Gets tuples from the Consumer and inserts them into the Insertable.
Field Summary | |
static long |
BUFFER_FULL_RETRY_PERIOD
Defines the sleep interval when no more tuples can be inserted into the producer (due to a full buffer) defined in ms. |
static long |
CONSUMER_RECREATE_PERIOD
Period between re-creating new consumer (if current one fails). |
int |
m_tuplesArchived
Number of tuples that have been archived by this thread. |
int |
m_tuplesLost
Number of tuples that have been lost by this thread. |
static int |
MAX_POP_COUNT
Maximum number of tuples to pop at a time. |
static long |
POP_INITIAL_PERIOD
Interval to wait before first pop in thread (ms). |
static long |
POP_RETRY_PERIOD
Interval to wait after a pop returns no tuples (ms). |
Fields inherited from class java.lang.Thread |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Method Summary | |
void |
close()
Stops the thread and closes the consumer. |
org.edg.info.system.ServletConnection |
getConsumerConnection()
Returns the servlet connection object used by the consumer. |
long |
getConsumerCreateTimeMillis()
|
int |
getConsumerId()
|
java.lang.String |
getConsumerURL()
|
java.lang.String |
getLastExceptionMessage()
|
long |
getLastInsertTimeMillis()
|
int |
getLastInsertTupleCount()
|
long |
getLastSuccessfulInsertTimeMillis()
|
int |
getNumberTuplesArchived()
|
int |
getNumberTuplesDropped()
|
java.lang.String |
getQuery()
|
long |
getQueryTimeoutMillis()
|
java.lang.String |
getStartTime()
|
java.lang.String |
getTableName()
|
java.lang.String |
getTupleStatus()
Gets a String giving the status of this archiver thread. |
boolean |
isProducerIsFull()
|
void |
run()
Main loop. |
Methods inherited from class java.lang.Thread |
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
public static final long BUFFER_FULL_RETRY_PERIOD
public static final long CONSUMER_RECREATE_PERIOD
public static final long POP_RETRY_PERIOD
public static final long POP_INITIAL_PERIOD
public static final int MAX_POP_COUNT
public int m_tuplesArchived
public int m_tuplesLost
Method Detail |
public java.lang.String getTupleStatus()
public org.edg.info.system.ServletConnection getConsumerConnection()
public void close()
public void run()
public boolean isProducerIsFull()
public java.lang.String getQuery()
public java.lang.String getStartTime()
public java.lang.String getTableName()
public int getNumberTuplesArchived()
public int getNumberTuplesDropped()
public int getConsumerId()
public java.lang.String getConsumerURL()
public long getConsumerCreateTimeMillis()
public long getQueryTimeoutMillis()
public long getLastInsertTimeMillis()
public long getLastSuccessfulInsertTimeMillis()
public int getLastInsertTupleCount()
public java.lang.String getLastExceptionMessage()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |