pt.lsts.imc.net

Class UDPTransport

java.lang.Object

pt.lsts.imc.net.UDPTransport

public class UDPTransport
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
UDPTransport()
UDPTransport(boolean isBroadcastEnable, boolean isMulticastEnable, int bindPort, int numberOfSenderThreads)
UDPTransport(boolean isBroadcastEnable, int bindPort, int numberOfSenderThreads)
UDPTransport(IMCDefinition defs)
UDPTransport(int numberOfSenderThreads)
UDPTransport(int bindPort, int numberOfSenderThreads)
UDPTransport(java.lang.String multicastAddress, int bindPort)
UDPTransport(java.lang.String multicastAddress, int bindPort, int numberOfSenderThreads)

Method Summary

Modifier and Type	Method and Description
void	addListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,IMCMessage> l, java.util.Collection<java.lang.String> typesToListen)
void	addMessageListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,IMCMessage> l)
void	addMessageListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,IMCMessage> l, java.util.Collection<java.lang.Integer> typesToListen)
void	dispatchMessage(IMCMessage req, pt.lsts.neptus.messages.listener.MessageInfo info)
int	getBindPort()
IMCDefinition	getDefinition()
int	getImcId()
int	getMaxBufferSize()
java.lang.String	getMulticastAddress()
int	getNumberOfSenderThreads()
int	getTimeoutMillis()
boolean	isBroadcastEnable()
boolean	isMulticastEnable()
boolean	isOnBindError()
boolean	isRunning()
boolean	isStopping()
static void	main(java.lang.String[] args)
void	printStatistics()
void	purge() Stops accepting new messages but waits until all the buffered messages are sent to the network before stopping the sending thread(s).
void	removeMessageListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,IMCMessage> l)
boolean	reStart()
static void	sendMessage(IMCMessage m, java.lang.String destination, int port)
boolean	sendMessage(java.lang.String destination, int port, IMCMessage message) Sends a message to the network
void	setBindPort(int bindPort)
void	setBroadcastEnable(boolean broadcastEnable)
void	setDefinition(IMCDefinition definition)
void	setImcId(int imc_id)
void	setIsMessageInfoNeeded(boolean b)
void	setMaxBufferSize(int maxBufferSize)
void	setMulticastAddress(java.lang.String multicastAddress)
void	setMulticastEnable(boolean multicastEnable)
void	setNumberOfSenderThreads(int numberOfSenderThreads)
void	setTimeoutMillis(int timeoutMillis)
void	stop() Interrupts all the sending threads abruptly.

Methods inherited from class java.lang.Object

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

Constructor Detail

UDPTransport

public UDPTransport(IMCDefinition defs)

UDPTransport

public UDPTransport()

UDPTransport

public UDPTransport(int numberOfSenderThreads)

Parameters:

numberOfSenderThreads -

UDPTransport

public UDPTransport(int bindPort,
                    int numberOfSenderThreads)

Parameters:

bindPort -

numberOfSenderThreads -

UDPTransport

public UDPTransport(boolean isBroadcastEnable,
                    int bindPort,
                    int numberOfSenderThreads)

UDPTransport

public UDPTransport(java.lang.String multicastAddress,
                    int bindPort,
                    int numberOfSenderThreads)

Parameters:

multicastAddress -

bindPort -

numberOfSenderThreads -

UDPTransport

public UDPTransport(boolean isBroadcastEnable,
                    boolean isMulticastEnable,
                    int bindPort,
                    int numberOfSenderThreads)

Parameters:

multicastAddress -

bindPort -

numberOfSenderThreads -

UDPTransport

public UDPTransport(java.lang.String multicastAddress,
                    int bindPort)

Parameters:

multicastAddress -

bindPort -

Method Detail

getDefinition

public IMCDefinition getDefinition()

setDefinition

public void setDefinition(IMCDefinition definition)

isOnBindError

public boolean isOnBindError()

Returns:

the isOnBindError

getBindPort

public int getBindPort()

Returns:

setBindPort

public void setBindPort(int bindPort)

Parameters:

bindPort -

getMulticastAddress

public java.lang.String getMulticastAddress()

Returns:

the multicastAddress

setMulticastAddress

public void setMulticastAddress(java.lang.String multicastAddress)

Parameters:

multicastAddress - the multicastAddress to set

isMulticastEnable

public boolean isMulticastEnable()

Returns:

the multicastEnable

setMulticastEnable

public void setMulticastEnable(boolean multicastEnable)

Parameters:

multicastEnable - the multicastEnable to set

isBroadcastEnable

public boolean isBroadcastEnable()

Returns:

the broadcastEnable

setBroadcastEnable

public void setBroadcastEnable(boolean broadcastEnable)

Parameters:

broadcastEnable - the broadcastEnable to set

getNumberOfSenderThreads

public int getNumberOfSenderThreads()

Returns:

the numberOfSenderThreads

setNumberOfSenderThreads

public void setNumberOfSenderThreads(int numberOfSenderThreads)

Parameters:

numberOfSenderThreads - the numberOfSenderThreads to set

getTimeoutMillis

public int getTimeoutMillis()

Returns:

the timeoutMillis

setTimeoutMillis

public void setTimeoutMillis(int timeoutMillis)

Parameters:

timeoutMillis - the timeoutMillis to set

getMaxBufferSize

public int getMaxBufferSize()

Returns:

the maxBufferSize

setMaxBufferSize

public void setMaxBufferSize(int maxBufferSize)

Parameters:

maxBufferSize - the maxBufferSize to set

reStart

public boolean reStart()

Returns:

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).

isRunning

public boolean isRunning()

Returns:

isStopping

public boolean isStopping()

Returns:

dispatchMessage

public void dispatchMessage(IMCMessage req,
                            pt.lsts.neptus.messages.listener.MessageInfo info)

Parameters:

req -

info -

setIsMessageInfoNeeded

public void setIsMessageInfoNeeded(boolean b)

sendMessage

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

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

Returns:

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

addMessageListener

public void addMessageListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,IMCMessage> l,
                               java.util.Collection<java.lang.Integer> typesToListen)

addListener

public void addListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,IMCMessage> l,
                        java.util.Collection<java.lang.String> typesToListen)

addMessageListener

public void addMessageListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,IMCMessage> l)

removeMessageListener

public void removeMessageListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,IMCMessage> l)

printStatistics

public void printStatistics()

sendMessage

public static void sendMessage(IMCMessage m,
                               java.lang.String destination,
                               int port)
                        throws java.lang.Exception

Throws:

java.lang.Exception

getImcId

public int getImcId()

Returns:

the imc_id

setImcId

public void setImcId(int imc_id)

main

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

Throws:

java.lang.Exception