public class UDPNetwork extends Network implements UDPNetworkMBean
Modifier and Type | Class and Description |
---|---|
(package private) class |
UDPNetwork.DatagramOutputStream
Class used to send messages with UDP packets.
|
(package private) class |
UDPNetwork.MessageAndIndex
A particular structure used to remember:
the sent message.
|
(package private) class |
UDPNetwork.MessageBuilder
Class used to transform UDP packets into a stream, to build the messages.
|
(package private) class |
UDPNetwork.NetServerIn |
(package private) class |
UDPNetwork.NetServerOut |
(package private) class |
UDPNetwork.NetworkInputStream |
(package private) class |
UDPNetwork.ServerInfo
Structure storing details about a particular remote network.
|
static interface |
UDPNetwork.ServerInfoMBean |
(package private) class |
UDPNetwork.WatchDog |
Network.NetworkAverageLoadTask
Modifier and Type | Field and Description |
---|---|
(package private) static int |
DATAGRAM_MAX_SIZE
The maximum number of bytes of one datagram
|
private UDPNetwork.NetServerIn |
netServerIn
Input component
|
private UDPNetwork.NetServerOut |
netServerOut
Output component
|
private Hashtable<SocketAddress,UDPNetwork.ServerInfo> |
serversInfo
An hashtable linking a socket address to some information about datagrams sent/received/acked
|
private DatagramSocket |
socket
A socket used to send and receive datagrams
|
private int |
socketReceiveBufferSize
Value of the SO_RCVBUF option for the DatagramSocket, that is the buffer size used by the
platform for input on the DatagramSocket.
|
private int |
socketSendBufferSize
Value of the SO_SNDBUF option for the DatagramSocket, that is the buffer size used by the
platform for output on the DatagramSocket
|
(package private) UDPNetwork.WatchDog |
watchDog |
ALREADY_DELIVERED, averageLoadTask, bootTSFN, DELIVER, domain, idxLS, logmon, name, nbMessageIn, nbMessageOut, port, qout, servers, serversFN, sid, WDActivationPeriod, WDNbRetryLevel1, WDNbRetryLevel2, WDRetryPeriod1, WDRetryPeriod2, WDRetryPeriod3
Constructor and Description |
---|
UDPNetwork() |
Modifier and Type | Method and Description |
---|---|
private String |
getMBeanName(String socketAddress) |
int |
getSocketReceiveBufferSize() |
int |
getSocketSendBufferSize() |
void |
init(String name,
int port,
short[] servers)
Initializes a new network component.
|
boolean |
isRunning()
Tests if the engine is alive.
|
void |
start()
Causes this engine to begin execution
|
void |
stop()
Forces the engine to stop executing
|
addServer, channelPostAndValidate, checkActive, delete, deleteMessage, deliver, delServer, getAverageLoad1, getAverageLoad15, getAverageLoad5, getBootTS, getDomainName, getMessageDest, getMessageSource, getName, getNbMessageReceived, getNbMessageSent, getNbWaitingMessages, getPort, getQueue, getStamp, getWDActivationPeriod, getWDNbRetryLevel1, getWDNbRetryLevel2, getWDRetryPeriod1, getWDRetryPeriod2, getWDRetryPeriod3, index, insert, post, postAndValidate, postMessage, prepareMessage, prepareMessageWithoutStamp, resetServer, restore, save, saveChannel, setMessageSource, setPort, setProperties, setStamp, setWDActivationPeriod, setWDNbRetryLevel1, setWDNbRetryLevel2, setWDRetryPeriod1, setWDRetryPeriod2, setWDRetryPeriod3, testBootTS, testRecvUpdate, toString, validate, validateChannel
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getAverageLoad1, getAverageLoad15, getAverageLoad5, getName, getNbMessageReceived, getNbMessageSent, getNbWaitingMessages, getWDActivationPeriod, getWDNbRetryLevel1, getWDNbRetryLevel2, getWDRetryPeriod1, getWDRetryPeriod2, getWDRetryPeriod3, setWDActivationPeriod, setWDNbRetryLevel1, setWDNbRetryLevel2, setWDRetryPeriod1, setWDRetryPeriod2, setWDRetryPeriod3, toString
static final int DATAGRAM_MAX_SIZE
private UDPNetwork.NetServerIn netServerIn
private UDPNetwork.NetServerOut netServerOut
private Hashtable<SocketAddress,UDPNetwork.ServerInfo> serversInfo
UDPNetwork.WatchDog watchDog
private DatagramSocket socket
private int socketReceiveBufferSize
private int socketSendBufferSize
public boolean isRunning()
NetworkMBean
isRunning
in interface MessageConsumer
isRunning
in interface NetworkMBean
MessageConsumer
is alive; false
otherwise.public void init(String name, int port, short[] servers) throws Exception
Network
Class.newInstance()
method for create
(without any parameter) the component, then we can initialize it with
this method.public void start() throws Exception
NetworkMBean
start
in interface MessageConsumer
start
in interface NetworkMBean
Exception
stop
public void stop()
NetworkMBean
stop
in interface MessageConsumer
stop
in interface NetworkMBean
start
public int getSocketReceiveBufferSize() throws SocketException
getSocketReceiveBufferSize
in interface UDPNetworkMBean
SocketException
public int getSocketSendBufferSize() throws SocketException
getSocketSendBufferSize
in interface UDPNetworkMBean
SocketException
Copyright © 2020 ScalAgent D.T.. All rights reserved.