fr.dyade.aaa.agent
Class NGNetwork

java.lang.Object
  extended byfr.dyade.aaa.agent.Network
      extended byfr.dyade.aaa.agent.StreamNetwork
          extended byfr.dyade.aaa.agent.NGNetwork
All Implemented Interfaces:
MessageConsumer, NetworkMBean

public class NGNetwork
extends StreamNetwork

NGNetwork is a new implementation of Network class using nio package.


Field Summary
 
Fields inherited from class fr.dyade.aaa.agent.Network
bootTSFN, domain, idxLS, logmon, name, port, qout, servers, serversFN, sid
 
Constructor Summary
NGNetwork()
          Creates a new network component.
 
Method Summary
 void init(java.lang.String name, int port, short[] servers)
          Initializes a new network component.
 boolean isRunning()
          Tests if the network component is alive.
 void post(fr.dyade.aaa.agent.Message msg)
          Adds a message in "ready to deliver" list.
 void start()
          Causes this network component to begin execution.
 void stop()
          Forces the network component to stop executing.
 java.lang.String toString()
          Returns a string representation of this consumer, including the daemon's name and status.
 void wakeup()
          Wakes up the watch-dog thread.
 
Methods inherited from class fr.dyade.aaa.agent.Network
delete, deliver, getDomainName, getName, getPort, getQueue, index, insert, restore, save, setPort, validate
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

NGNetwork

public NGNetwork()
Creates a new network component.

Method Detail

init

public void init(java.lang.String name,
                 int port,
                 short[] servers)
          throws java.lang.Exception
Initializes a new network component. This method is used in order to easily creates and configure a Network component from a class name. So we can use the Class.newInstance() method for create (whitout any parameter) the component, then we can initialize it with this method.
This method initializes the logical clock for the domain.

Overrides:
init in class StreamNetwork
Parameters:
name - The domain name.
port - The listen port.
servers - The list of servers directly accessible from this network interface.
Throws:
java.lang.Exception
See Also:
Network

post

public void post(fr.dyade.aaa.agent.Message msg)
          throws java.lang.Exception
Adds a message in "ready to deliver" list. This method allocates a new time stamp to the message ; be Careful, changing the stamp imply the filename change too.

Specified by:
post in interface MessageConsumer
Overrides:
post in class Network
Throws:
java.lang.Exception

start

public void start()
           throws java.lang.Exception
Causes this network component to begin execution.

Throws:
java.lang.Exception
See Also:
stop

wakeup

public void wakeup()
Wakes up the watch-dog thread.


stop

public void stop()
Forces the network component to stop executing.

See Also:
start

isRunning

public boolean isRunning()
Tests if the network component is alive.

Returns:
true if this MessageConsumer is alive; false otherwise.

toString

public java.lang.String toString()
Returns a string representation of this consumer, including the daemon's name and status.

Overrides:
toString in class Network
Returns:
A string representation of this consumer.


Copyright ? 2004 Scalagent - All rights reserved