fr.dyade.aaa.agent
Class HttpNetwork
- MessageConsumer, NetworkMBean
HttpNetwork is a simple implementation of StreamNetwork
based on HTTP 1.1 protocol.
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.
|
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.
|
delete , deliver , getDomainName , getName , getPort , getQueue , index , init , insert , post , restore , save , setPort , toString , validate |
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.
HttpNetwork
public HttpNetwork()
Creates a new network component.
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.
- init in interface StreamNetwork
name
- The domain name.port
- The listen port.servers
- The list of servers directly accessible from this
network interface.
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
toString
public String toString()
Returns a string representation of this consumer, including the
daemon's name and status.
- toString in interface Network
- A string representation of this consumer.
wakeup
public void wakeup()
Wakes up the watch-dog thread.
Copyright B) 2004 Scalagent - All rights reserved