fr.dyade.aaa.agent
Class NGNetwork

java.lang.Object
  fr.dyade.aaa.agent.Network
      fr.dyade.aaa.agent.StreamNetwork
          fr.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.