fr.dyade.aaa.agent

Class HttpNetwork

Implemented Interfaces:
MessageConsumer, NetworkMBean

public class HttpNetwork
extends StreamNetwork

HttpNetwork is a simple implementation of StreamNetwork based on HTTP 1.1 protocol.

Field Summary

protected long
activationPeriod
Period of time between two activation of NetServerOut, it matchs to the time between two requests from the client to the server when there is no message to transmit from client to server.

Fields inherited from class fr.dyade.aaa.agent.Network

bootTSFN, domain, idxLS, logmon, name, port, qout, servers, serversFN, sid

Constructor Summary

HttpNetwork()
Creates a new network component.

Method Summary

protected fr.dyade.aaa.agent.Message
getReply(InputStream is)
protected fr.dyade.aaa.agent.Message
getRequest(InputStream is)
void
init(String name, int port, short[] servers)
Initializes a new network component.
boolean
isRunning()
Tests if the network component is alive.
protected String
readLine(InputStream is)
protected void
sendReply(fr.dyade.aaa.agent.Message msg, OutputStream os)
protected void
sendRequest(fr.dyade.aaa.agent.Message msg, OutputStream os)
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.

Methods inherited from class fr.dyade.aaa.agent.StreamNetwork

init

Methods inherited from class fr.dyade.aaa.agent.Network

delete, deliver, getDomainName, getName, getPort, getQueue, index, init, insert, post, restore, save, setPort, toString, validate

Field Details

activationPeriod

protected long activationPeriod
Period of time between two activation of NetServerOut, it matchs to the time between two requests from the client to the server when there is no message to transmit from client to server. This value can be adjusted for all HttpNetwork components by setting ActivationPeriod global property or for a particular network by setting \.ActivationPeriod specific property.

Theses properties can be fixed either from java launching command, or in a3servers.xml configuration file.

Constructor Details

HttpNetwork

public HttpNetwork()
Creates a new network component.

Method Details

getReply

protected fr.dyade.aaa.agent.Message getReply(InputStream is)
            throws Exception


getRequest

protected fr.dyade.aaa.agent.Message getRequest(InputStream is)
            throws Exception


init

public void init(String name,
                 int port,
                 short[] servers)
            throws 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 interface StreamNetwork

Parameters:
name - The domain name.
port - The listen port.
servers - The list of servers directly accessible from this network interface.


isRunning

public boolean isRunning()
Tests if the network component is alive.
Specified by:
isRunning in interface MessageConsumer
isRunning in interface NetworkMBean

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


readLine

protected String readLine(InputStream is)
            throws IOException


sendReply

protected void sendReply(fr.dyade.aaa.agent.Message msg,
                         OutputStream os)
            throws Exception


sendRequest

protected void sendRequest(fr.dyade.aaa.agent.Message msg,
                           OutputStream os)
            throws Exception


start

public void start()
            throws Exception
Causes this network component to begin execution.
Specified by:
start in interface MessageConsumer
start in interface NetworkMBean


stop

public void stop()
Forces the network component to stop executing.
Specified by:
stop in interface MessageConsumer
stop in interface NetworkMBean


toString

public String toString()
Returns a string representation of this consumer, including the daemon's name and status.
Overrides:
toString in interface Network

Returns:
A string representation of this consumer.


wakeup

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


Copyright B) 2004 Scalagent - All rights reserved