org.jgroups.blocks
Class TCPConnectionMap.TCPConnection.Sender

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


Copyright © 1998-2012 Bela Ban / Red Hat. All Rights Reserved.