pt.lsts.neptus.comm.transports.tcp

Class TCPTransport

java.lang.Object

pt.lsts.neptus.comm.transports.tcp.TCPTransport

public class TCPTransport
extends java.lang.Object

Author:

pdias

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.LinkedHashSet<TCPMessageListener>	listeners

Constructor Summary

Constructors

Constructor and Description
TCPTransport()
TCPTransport(int bindPort)

Method Summary

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.

Methods inherited from class java.lang.Object

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

Field Detail

listeners

protected java.util.LinkedHashSet<TCPMessageListener> listeners

Constructor Detail

TCPTransport

public TCPTransport()

TCPTransport

public TCPTransport(int bindPort)

Method Detail

reStart

public boolean reStart()

resolveAddress

protected java.net.InetAddress resolveAddress(java.lang.String multicastAddress)
                                       throws java.net.UnknownHostException

Parameters:

multicastAddress -

Returns:

Throws:

java.net.UnknownHostException

stop

public void stop()

Interrupts all the sending threads abruptly.

See Also:

#purge()}

purge

public void purge()

Stops accepting new messages but waits until all the buffered messages are sent to the network before stopping the sending thread(s).

connectIfNotConnected

public boolean connectIfNotConnected(java.lang.String host,
                                     int port)

Parameters:

host -

port -

Returns:

isConnectionEstablished

public boolean isConnectionEstablished(java.lang.String host,
                                       int port)

Parameters:

host -

port -

Returns:

getBindPort

public int getBindPort()

Returns:

the bindPort

setBindPort

public void setBindPort(int bindPort)

Parameters:

bindPort - the bindPort to set

connect

protected void connect()

disconnect

protected void disconnect()

Disconnect and close the TCP server socket.

Throws:

vrml.eai.ConnectionException - if a network error occurs

isRunning

public boolean isRunning()

Returns:

isRunningNormally

public boolean isRunningNormally()

Returns:

isOnBindError

public boolean isOnBindError()

Returns:

the isOnBindError

addListener

public boolean addListener(TCPMessageListener listener)

Parameters:

listener -

Returns:

removeListener

public boolean removeListener(TCPMessageListener listener)

Parameters:

listener -

Returns:

sendMessage

public boolean sendMessage(java.lang.String destination,
                           int port,
                           byte[] buffer)

Sends a message to the network

Parameters:

destination - A valid hostname like "whale.fe.up.pt" or "127.0.0.1"

port - The destination's port

buffer -

Returns:

true meaning that the message was put on the send queue, and false if it was not put on the send queue.

sendMessage

public boolean sendMessage(java.lang.String destination,
                           int port,
                           byte[] buffer,
                           DeliveryListener deliveryListener)

Sends a message to the network

Parameters:

destination - A valid hostname like "whale.fe.up.pt" or "127.0.0.1"

port - The destination's port

buffer -

deliveryListener -

Returns:

true meaning that the message was put on the send queue, and false if it was not put on the send queue.

getActiveNumberOfConnections

public long getActiveNumberOfConnections()

Returns:

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception