|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
org.edg.info.Messenger
Messages that can't fail can be send by implementations of this. Clients call sendMessage(). Subclasses implement tryToSendMessage(), and should not remove the message from messages unless the message was sent, or if certain exceptions are thrown.
Field Summary | |
static int |
ERROR
Result code indicating that message failed and should be retried. |
static int |
FATAL
Result code indicating that message failed and should be removed from list. |
static int |
FIREWALL
Result code indicating that a firewall caused the message to fail, so the message and all messages to the same host should be removed from the list. |
static int |
OK
Result code indicating that message was sent successfully so can be removed from list. |
static int |
READ_TIMEOUT
Result code indicating that the read time-out was reached. |
static java.lang.String[] |
RESULT_CODES
String representations of result codes. |
Fields inherited from class java.lang.Thread |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Method Summary | |
void |
flushQueue(java.lang.String queueName,
java.lang.String host)
|
Message |
getCopyOfCurrentMessageInQueue()
|
Message[] |
getCopyOfMessageQueue()
|
java.lang.Object[] |
getMessages()
DOCUMENT ME! |
long |
getNotifyInterval()
DOCUMENT ME! |
Messenger |
getSlowQueue()
DOCUMENT ME! |
void |
run()
Main thread loop. |
void |
setRootMessenger(Messenger rootMessenger)
DOCUMENT ME! |
void |
startAll()
Starts this thread and all "slower" messengers that it uses. |
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 int OK
public static final int ERROR
public static final int FATAL
public static final int FIREWALL
public static final int READ_TIMEOUT
public static final java.lang.String[] RESULT_CODES
Method Detail |
public void setRootMessenger(Messenger rootMessenger)
rootMessenger
- DOCUMENT ME!public void startAll()
public void run()
public Message[] getCopyOfMessageQueue()
public java.lang.Object[] getMessages()
public Message getCopyOfCurrentMessageInQueue()
public void flushQueue(java.lang.String queueName, java.lang.String host)
queueName
- host
- public Messenger getSlowQueue()
public long getNotifyInterval()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |