public class TCPTransport
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected java.util.LinkedHashSet<TCPMessageListener> |
listeners |
Constructor and Description |
---|
TCPTransport() |
TCPTransport(int bindPort) |
Modifier and Type | Method and Description |
---|---|
boolean |
addListener(TCPMessageListener listener) |
protected void |
connect() |
boolean |
connectIfNotConnected(java.lang.String host,
int port) |
protected void |
disconnect()
Disconnect and close the TCP server socket.
|
long |
getActiveNumberOfConnections() |
int |
getBindPort() |
boolean |
isConnectionEstablished(java.lang.String host,
int port) |
boolean |
isOnBindError() |
boolean |
isRunning() |
boolean |
isRunningNormally() |
static void |
main(java.lang.String[] args) |
void |
purge()
Stops accepting new messages but waits until all the buffered
messages are sent to the network before stopping the sending thread(s).
|
boolean |
removeListener(TCPMessageListener listener) |
protected java.net.InetAddress |
resolveAddress(java.lang.String multicastAddress) |
boolean |
reStart() |
boolean |
sendMessage(java.lang.String destination,
int port,
byte[] buffer)
Sends a message to the network
|
boolean |
sendMessage(java.lang.String destination,
int port,
byte[] buffer,
DeliveryListener deliveryListener)
Sends a message to the network
|
void |
setBindPort(int bindPort) |
void |
stop()
Interrupts all the sending threads abruptly.
|
protected java.util.LinkedHashSet<TCPMessageListener> listeners
public TCPTransport()
public TCPTransport(int bindPort)
public boolean reStart()
protected java.net.InetAddress resolveAddress(java.lang.String multicastAddress) throws java.net.UnknownHostException
multicastAddress
- java.net.UnknownHostException
public void stop()
#purge()}
public void purge()
public boolean connectIfNotConnected(java.lang.String host, int port)
host
- port
- public boolean isConnectionEstablished(java.lang.String host, int port)
host
- port
- public int getBindPort()
public void setBindPort(int bindPort)
bindPort
- the bindPort to setprotected void connect()
protected void disconnect()
vrml.eai.ConnectionException
- if a network error occurspublic boolean isRunning()
public boolean isRunningNormally()
public boolean isOnBindError()
public boolean addListener(TCPMessageListener listener)
listener
- public boolean removeListener(TCPMessageListener listener)
listener
- public boolean sendMessage(java.lang.String destination, int port, byte[] buffer)
destination
- A valid hostname like "whale.fe.up.pt" or "127.0.0.1"port
- The destination's portbuffer
- public boolean sendMessage(java.lang.String destination, int port, byte[] buffer, DeliveryListener deliveryListener)
destination
- A valid hostname like "whale.fe.up.pt" or "127.0.0.1"port
- The destination's portbuffer
- deliveryListener
- public long getActiveNumberOfConnections()
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
Copyright © 2004-2014 FEUP-LSTS and Neptus developers. All Rights Reserved.