public class NGNetwork extends StreamNetwork
NGNetwork
is a new implementation of Network
class using nio package.Modifier and Type | Class and Description |
---|---|
(package private) class |
NGNetwork.CnxHandler |
(package private) class |
NGNetwork.Dispatcher |
(package private) class |
NGNetwork.MessageVector |
(package private) class |
NGNetwork.NetServer |
Network.NetworkAverageLoadTask
Modifier and Type | Field and Description |
---|---|
(package private) NGNetwork.Dispatcher |
dispatcher |
(package private) NGNetwork.NetServer[] |
dmon |
(package private) NGNetwork.CnxHandler[] |
handlers |
(package private) static int |
Kb |
(package private) ServerSocketChannel |
listen |
(package private) static int |
Mb |
(package private) static int |
NbNetServer |
(package private) Selector |
selector |
(package private) static int |
SO_BUFSIZE |
backlog, CnxRetry, ConnectTimeout, inLocalAddr, outLocalAddr, outLocalPort, serverSocketFactory, socketFactory, SoLinger, SoTimeout, TcpNoDelay
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 |
---|
NGNetwork()
Creates a new network component.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
close() |
(package private) void |
cnxStart(SocketChannel channel) |
(package private) NGNetwork.CnxHandler |
getHandler(short sid) |
void |
init(String name,
int port,
short[] servers)
Initializes a new network component.
|
boolean |
isRunning()
Tests if the network component is alive.
|
(package private) void |
open() |
void |
start()
Causes this network component to begin execution.
|
void |
stop()
Forces the network component to stop executing.
|
String |
toString()
Returns a string representation of this consumer, including the
daemon's name and status.
|
void |
wakeup()
Wakes up the watch-dog thread.
|
createServerSocket, createServerSocket, createSocket, createSocket, createSocket, setProperties, setSocketOption
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, isPrior, post, postAndValidate, postMessage, prepareMessage, prepareMessageWithoutStamp, resetServer, restore, save, saveChannel, setMessageSource, setPort, setStamp, setWDActivationPeriod, setWDNbRetryLevel1, setWDNbRetryLevel2, setWDRetryPeriod1, setWDRetryPeriod2, setWDRetryPeriod3, testBootTS, testRecvUpdate, validate, validateChannel
static final int Kb
static final int Mb
static final int SO_BUFSIZE
Selector selector
NGNetwork.Dispatcher dispatcher
NGNetwork.NetServer[] dmon
static final int NbNetServer
NGNetwork.CnxHandler[] handlers
ServerSocketChannel listen
public void init(String name, int port, short[] servers) throws Exception
Class.newInstance()
method for create
(whitout any parameter) the component, then we can initialize it with
this method.init
in class StreamNetwork
name
- The domain name.port
- The listen port.servers
- The list of servers directly accessible from this
network interface.Exception
- an error occurs.Network
void open() throws IOException
IOException
void close()
public void start() throws Exception
Exception
- an error occurs.stop
final NGNetwork.CnxHandler getHandler(short sid)
public void wakeup()
public void stop()
start
public boolean isRunning()
MessageConsumer
is alive; false
otherwise.public String toString()
toString
in interface NetworkMBean
toString
in class Network
void cnxStart(SocketChannel channel) throws IOException
IOException
Copyright © 2022 ScalAgent D.T.. All rights reserved.