org.jgroups.blocks
Class TCPConnectionMap.TCPConnection.Sender

java.lang.Object
  org.jgroups.blocks.TCPConnectionMap.TCPConnection.Sender

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

TCPConnectionMap.TCPConnection

protected class TCPConnectionMap.TCPConnection.Sender
extends java.lang.Object
implements java.lang.Runnable

Field Summary

protected java.util.concurrent.atomic.AtomicBoolean

running

Constructor Summary

TCPConnectionMap.TCPConnection.Sender(ThreadFactory tf, int send_queue_size)

Method Summary

void	addToQueue(byte[] data)
boolean	canRun()
boolean	isRunning()
void	run()
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

running

protected final java.util.concurrent.atomic.AtomicBoolean running

Constructor Detail

TCPConnectionMap.TCPConnection.Sender

public TCPConnectionMap.TCPConnection.Sender(ThreadFactory tf,
                                             int send_queue_size)

Method Detail

addToQueue

public void addToQueue(byte[] data)
                throws java.lang.Exception

Throws:

java.lang.Exception

start

public void start()

stop

public void stop()

isRunning

public boolean isRunning()

canRun

public boolean canRun()

run

public void run()

Specified by:

run in interface java.lang.Runnable