org.livetribe.slp.spi
Class Converger
java.lang.Object
org.livetribe.slp.spi.net.UDPConnector.Acceptor
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) $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Converger
protected Converger(UDPConnector connector)
throws SocketException
- Throws:
SocketException
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.