pt.lsts.neptus.comm.transports

Class ImcTcpTransport

java.lang.Object

pt.lsts.neptus.comm.transports.ImcTcpTransport

public class ImcTcpTransport
extends java.lang.Object

Author:

pdias

Constructor Summary

Constructors

Constructor and Description
ImcTcpTransport(int bindPort, pt.lsts.imc.IMCDefinition imcDefinition)

Method Summary

Modifier and Type	Method and Description
boolean	addListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,pt.lsts.imc.IMCMessage> listener)
long	getActiveNumberOfConnections()
int	getBindPort()
TCPTransport	getTcpTransport()
boolean	isConnectionEstablished(java.lang.String host, int port)
boolean	isOnBindError()
boolean	isRunning()
boolean	isRunningNormally()
static void	main(java.lang.String[] args)
void	purge()
boolean	removeListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,pt.lsts.imc.IMCMessage> listener)
void	reStart()
boolean	sendMessage(java.lang.String destination, int port, pt.lsts.imc.IMCMessage message)
boolean	sendMessage(java.lang.String destination, int port, pt.lsts.imc.IMCMessage message, MessageDeliveryListener deliveryListener)
void	setBindPort(int bindPort)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ImcTcpTransport

public ImcTcpTransport(int bindPort,
                       pt.lsts.imc.IMCDefinition imcDefinition)

Method Detail

getBindPort

public int getBindPort()

Returns:

the bindPort

setBindPort

public void setBindPort(int bindPort)

Parameters:

bindPort - the bindPort to set

isRunning

public boolean isRunning()

Returns:

isRunningNormally

public boolean isRunningNormally()

Returns:

getTcpTransport

public TCPTransport getTcpTransport()

Returns:

the udpTransport

addListener

public boolean addListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,pt.lsts.imc.IMCMessage> listener)

Parameters:

listener -

Returns:

removeListener

public boolean removeListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,pt.lsts.imc.IMCMessage> listener)

Parameters:

listener -

Returns:

sendMessage

public boolean sendMessage(java.lang.String destination,
                           int port,
                           pt.lsts.imc.IMCMessage message)

Parameters:

destination -

port -

message -

sendMessage

public boolean sendMessage(java.lang.String destination,
                           int port,
                           pt.lsts.imc.IMCMessage message,
                           MessageDeliveryListener deliveryListener)

Parameters:

destination -

port -

message -

deliveryListener -

stop

public void stop()

purge

public void purge()

reStart

public void reStart()

isOnBindError

public boolean isOnBindError()

getActiveNumberOfConnections

public long getActiveNumberOfConnections()

Returns:

isConnectionEstablished

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

main

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

Parameters:

args -

Throws:

MiddlewareException

java.lang.Exception