public class UDPTransport
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected java.util.LinkedHashSet<UDPMessageListener> |
listeners |
Constructor and Description |
---|
UDPTransport() |
UDPTransport(boolean isBroadcastEnable,
int bindPort,
int numberOfSenderThreads) |
UDPTransport(int numberOfSenderThreads) |
UDPTransport(int bindPort,
int numberOfSenderThreads) |
UDPTransport(java.lang.String multicastAddress,
int bindPort) |
UDPTransport(java.lang.String multicastAddress,
int bindPort,
int numberOfSenderThreads) |
Modifier and Type | Method and Description |
---|---|
boolean |
addListener(UDPMessageListener listener) |
int |
getBindPort() |
int |
getMaxBufferSize() |
java.lang.String |
getMulticastAddress() |
int |
getNumberOfSenderThreads() |
int |
getTimeoutMillis() |
protected boolean |
isBroadcastActive() |
boolean |
isBroadcastEnable() |
protected boolean |
isMulticastActive() |
boolean |
isMulticastEnable() |
boolean |
isOnBindError() |
boolean |
isRunning() |
boolean |
isRunningNormally() |
boolean |
isStopping() |
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(UDPMessageListener 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) |
protected void |
setBroadcastActive(boolean broadcastActive) |
void |
setBroadcastEnable(boolean broadcastEnable) |
void |
setMaxBufferSize(int maxBufferSize) |
protected void |
setMulticastActive(boolean multicastActive) |
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.
|
protected java.util.LinkedHashSet<UDPMessageListener> listeners
public UDPTransport()
public UDPTransport(int numberOfSenderThreads)
numberOfSenderThreads
- public UDPTransport(int bindPort, int numberOfSenderThreads)
bindPort
- numberOfSenderThreads
- public UDPTransport(boolean isBroadcastEnable, int bindPort, int numberOfSenderThreads)
public UDPTransport(java.lang.String multicastAddress, int bindPort, int numberOfSenderThreads)
multicastAddress
- bindPort
- numberOfSenderThreads
- public UDPTransport(java.lang.String multicastAddress, int bindPort)
multicastAddress
- bindPort
- public boolean isOnBindError()
public int getBindPort()
public void setBindPort(int bindPort)
bindPort
- public java.lang.String getMulticastAddress()
public void setMulticastAddress(java.lang.String multicastAddress)
multicastAddress
- the multicastAddress to setpublic boolean isMulticastEnable()
public void setMulticastEnable(boolean multicastEnable)
multicastEnable
- the multicastEnable to setprotected boolean isMulticastActive()
protected void setMulticastActive(boolean multicastActive)
multicastActive
- the multicastActive to setpublic boolean isBroadcastEnable()
public void setBroadcastEnable(boolean broadcastEnable)
broadcastEnable
- the broadcastEnable to setprotected boolean isBroadcastActive()
protected void setBroadcastActive(boolean broadcastActive)
broadcastActive
- the broadcastActive to setpublic int getNumberOfSenderThreads()
public void setNumberOfSenderThreads(int numberOfSenderThreads)
numberOfSenderThreads
- the numberOfSenderThreads to setpublic int getTimeoutMillis()
public void setTimeoutMillis(int timeoutMillis)
timeoutMillis
- the timeoutMillis to setpublic int getMaxBufferSize()
public void setMaxBufferSize(int maxBufferSize)
maxBufferSize
- the maxBufferSize to setprotected java.net.InetAddress resolveAddress(java.lang.String multicastAddress) throws java.net.UnknownHostException
multicastAddress
- java.net.UnknownHostException
public boolean reStart()
public void stop()
#purge()}
public void purge()
public boolean isRunning()
public boolean isRunningNormally()
public boolean isStopping()
public boolean addListener(UDPMessageListener listener)
listener
- public boolean removeListener(UDPMessageListener 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 static void main(java.lang.String[] args) throws java.lang.Exception
args
- java.lang.Exception
Copyright © 2004-2014 FEUP-LSTS and Neptus developers. All Rights Reserved.