org.xnap.plugin.opennap.net.msg
Class SendWorker

java.lang.Object
  extended by org.xnap.plugin.opennap.net.msg.SendWorker
All Implemented Interfaces:
java.lang.Runnable

public class SendWorker
extends java.lang.Object
implements java.lang.Runnable


Field Summary
static long MAX_TIME_PER_SERVER
          Spent that much time on a queue per run.
static long STALL_INTERVAL
           
 
Constructor Summary
SendWorker(java.lang.String name, MessageSender parent)
           
 
Method Summary
 void run()
           
 boolean sendMessages(SendQueue q)
          Sends the message from q until timeout is expired.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

MAX_TIME_PER_SERVER

public static long MAX_TIME_PER_SERVER
Spent that much time on a queue per run.


STALL_INTERVAL

public static long STALL_INTERVAL
Constructor Detail

SendWorker

public SendWorker(java.lang.String name,
                  MessageSender parent)
Method Detail

run

public void run()
Specified by:
run in interface java.lang.Runnable

sendMessages

public boolean sendMessages(SendQueue q)
Sends the message from q until timeout is expired.

Returns:
true, if q has more messages, meaning it should be requed


Copyright © 2001-2005 XNap Team. All Rights Reserved.