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

java.lang.Object
  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