|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectfr.dyade.aaa.agent.Network
fr.dyade.aaa.agent.StreamNetwork
fr.dyade.aaa.agent.HttpNetwork
public class HttpNetwork
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 matches 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, nbMessageIn, nbMessageOut, port, qout, servers, serversFN, sid |
Constructor Summary | |
---|---|
HttpNetwork()
Creates a new network component. |
Method Summary | |
---|---|
long |
getActivationPeriod()
Gets the activationPeriod value. |
long |
getNbDaemon()
Gets the NbDaemon value. |
java.lang.String |
getProxyhost()
Gets the proxyhost value. |
long |
getProxyport()
Gets the proxyport value. |
protected void |
getReply(java.io.InputStream is,
fr.dyade.aaa.agent.HttpNetwork.NetworkInputStream nis,
byte[] buf)
|
protected short |
getRequest(java.io.InputStream is,
fr.dyade.aaa.agent.HttpNetwork.NetworkInputStream nis,
byte[] buf)
|
protected int |
handle(fr.dyade.aaa.agent.Message msgout,
fr.dyade.aaa.agent.HttpNetwork.NetworkInputStream nis)
|
void |
init(java.lang.String name,
int port,
short[] servers)
Initializes a new network component. |
boolean |
isRunning()
Tests if the network component is alive. |
protected void |
sendReply(fr.dyade.aaa.agent.Message msg,
java.io.OutputStream os,
fr.dyade.aaa.agent.HttpNetwork.NetworkOutputStream nos,
int ack,
long currentTimeMillis)
|
protected void |
sendRequest(fr.dyade.aaa.agent.Message msg,
java.io.OutputStream os,
fr.dyade.aaa.agent.HttpNetwork.NetworkOutputStream nos,
int ack,
long currentTimeMillis)
|
void |
setActivationPeriod(long activationPeriod)
Sets the activationPeriod value. |
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.StreamNetwork |
---|
setProperties |
Methods inherited from class fr.dyade.aaa.agent.Network |
---|
addServer, delete, deliver, delServer, getAverageLoad1, getAverageLoad15, getAverageLoad5, getDomainName, getName, getNbMessageReceived, getNbMessageSent, getNbWaitingMessages, getPort, getQueue, getStamp, getWDActivationPeriod, getWDNbRetryLevel1, getWDNbRetryLevel2, getWDRetryPeriod1, getWDRetryPeriod2, getWDRetryPeriod3, index, insert, post, restore, save, setPort, setStamp, setWDActivationPeriod, setWDNbRetryLevel1, setWDNbRetryLevel2, setWDRetryPeriod1, setWDRetryPeriod2, setWDRetryPeriod3, validate |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface fr.dyade.aaa.agent.NetworkMBean |
---|
getAverageLoad1, getAverageLoad15, getAverageLoad5, getName, getNbMessageReceived, getNbMessageSent, getNbWaitingMessages, getWDActivationPeriod, getWDNbRetryLevel1, getWDNbRetryLevel2, getWDRetryPeriod1, getWDRetryPeriod2, getWDRetryPeriod3, setWDActivationPeriod, setWDNbRetryLevel1, setWDNbRetryLevel2, setWDRetryPeriod1, setWDRetryPeriod2, setWDRetryPeriod3 |
Field Detail |
---|
protected long activationPeriod
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. By default,
its value is 10000 (10s).
Constructor Detail |
---|
public HttpNetwork()
Method Detail |
---|
public java.lang.String getProxyhost()
getProxyhost
in interface HttpNetworkMBean
public long getProxyport()
getProxyport
in interface HttpNetworkMBean
public long getActivationPeriod()
getActivationPeriod
in interface HttpNetworkMBean
public void setActivationPeriod(long activationPeriod)
setActivationPeriod
in interface HttpNetworkMBean
activationPeriod
- the activationPeriod valuepublic long getNbDaemon()
getNbDaemon
in interface HttpNetworkMBean
public void init(java.lang.String name, int port, short[] servers) throws java.lang.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.
java.lang.Exception
Network
public void start() throws java.lang.Exception
start
in interface MessageConsumer
start
in interface NetworkMBean
java.lang.Exception
stop
public void wakeup()
public void stop()
stop
in interface MessageConsumer
stop
in interface NetworkMBean
start
public boolean isRunning()
isRunning
in interface MessageConsumer
isRunning
in interface NetworkMBean
MessageConsumer
is alive; false
otherwise.public java.lang.String toString()
toString
in interface NetworkMBean
toString
in class Network
protected void sendRequest(fr.dyade.aaa.agent.Message msg, java.io.OutputStream os, fr.dyade.aaa.agent.HttpNetwork.NetworkOutputStream nos, int ack, long currentTimeMillis) throws java.lang.Exception
java.lang.Exception
protected final short getRequest(java.io.InputStream is, fr.dyade.aaa.agent.HttpNetwork.NetworkInputStream nis, byte[] buf) throws java.lang.Exception
java.lang.Exception
protected final void sendReply(fr.dyade.aaa.agent.Message msg, java.io.OutputStream os, fr.dyade.aaa.agent.HttpNetwork.NetworkOutputStream nos, int ack, long currentTimeMillis) throws java.lang.Exception
java.lang.Exception
protected void getReply(java.io.InputStream is, fr.dyade.aaa.agent.HttpNetwork.NetworkInputStream nis, byte[] buf) throws java.lang.Exception
java.lang.Exception
protected int handle(fr.dyade.aaa.agent.Message msgout, fr.dyade.aaa.agent.HttpNetwork.NetworkInputStream nis) throws java.lang.Exception
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |