org.livetribe.slp.spi
Class Converger

java.lang.Object
  extended by org.livetribe.slp.spi.net.UDPConnector.Acceptor
      extended by org.livetribe.slp.spi.Converger
All Implemented Interfaces:
Runnable, MessageListener

public abstract class Converger
extends UDPConnector.Acceptor
implements MessageListener

Version:
$Rev: 200 $ $Date: 2006-08-09 14:17:10 +0200 (Wed, 09 Aug 2006) $

Field Summary
 
Fields inherited from class org.livetribe.slp.spi.net.UDPConnector.Acceptor
logger
 
Constructor Summary
protected Converger(UDPConnector connector)
           
 
Method Summary
protected  void add(Message message)
           
 void await(long time)
           
 void close()
           
protected  DatagramSocket getDatagramSocket()
           
 boolean isEmpty()
           
 void lock()
           
 Rply pop()
           
 void run()
           
abstract  void send(UDPConnector connector, byte[] bytes)
           
protected  void signalAll()
           
 void unlock()
           
 
Methods inherited from class org.livetribe.slp.spi.net.UDPConnector.Acceptor
getMaxTransmissionUnit, getMulticastAddress, getPort, handle
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.livetribe.slp.spi.net.MessageListener
handle
 

Constructor Detail

Converger

protected Converger(UDPConnector connector)
             throws SocketException
Throws:
SocketException
Method Detail

getDatagramSocket

protected DatagramSocket getDatagramSocket()

send

public abstract void send(UDPConnector connector,
                          byte[] bytes)
                   throws IOException
Throws:
IOException

close

public void close()

lock

public void lock()

unlock

public void unlock()

await

public void await(long time)
           throws InterruptedException
Throws:
InterruptedException

signalAll

protected void signalAll()

isEmpty

public boolean isEmpty()

add

protected void add(Message message)

pop

public Rply pop()

run

public void run()
Specified by:
run in interface Runnable


Copyright © 2006-2012 LiveTribe. All Rights Reserved.