public final class MsgInterface
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
(package private) java.lang.String |
ACKNOWLEGEMENT |
private int |
agentCount |
(package private) java.lang.String |
BIRTH_DEMANDED |
(package private) java.lang.String |
BIRTH_REQUESTED |
private java.lang.String |
currentTask |
private java.lang.String |
ipa |
private java.lang.String |
loadStatus |
private int |
mwHealth |
(package private) int |
NONRESPONSIVE |
private java.lang.String |
paramList |
private java.lang.String |
readBuffer |
(package private) java.lang.String |
REQUEST_REFUSED |
(package private) java.lang.String |
RESERVED |
(package private) java.lang.String |
SAY_PARAMETER_LIST |
private static java.net.ServerSocket |
serverSocket |
private static java.net.Socket |
socket |
private java.lang.String |
startAgent |
(package private) java.lang.String |
STATUS_REPORT |
(package private) java.lang.String |
STATUS_REQUESTED |
Constructor and Description |
---|
MsgInterface(java.net.ServerSocket newServerSocket,
int currentCount,
java.lang.String hostIPA)
this is the constructor.
|
Modifier and Type | Method and Description |
---|---|
private void |
evaluateMidwifeMessage(java.io.InputStream inStream,
java.io.OutputStream outStream)
this is a branching, CONSTANT matching, Boolean evaluator.
|
private void |
flushBuffers(java.io.OutputStream outStream,
java.io.InputStream inStream)
this flushes data in network buffers associated with the IO streams.
|
java.lang.String |
getArguments(java.lang.String bufferContents)
this returns the string arguments embedded in the buffered parameter
describing the requested Agency (instantiation).
|
int |
getLoadingStatus(java.lang.String midwifeIPA,
int port)
this is the load status requester.
|
java.lang.String |
getParamList()
this returns the parameter list of new agent instantiation particulars.
|
java.lang.String |
getTasking()
this returns the last message received in inter-Midwife communications.
|
void |
main()
this is the MsgInterface main execution thread.
|
private boolean |
receive(java.io.InputStream inStream,
java.lang.String user)
this method blocks while receiving data from the network interface,
converts the received data (when/if it arrives) into a String, stores
what was received in the GLOBAL readBuffer and then returns True if
the activity was successful.
|
private boolean |
send(java.lang.String botshaft,
java.io.OutputStream outStream)
this converts a String message (botschaft) into a byte array
and then transmits that array over the network.
|
void |
setAgentCount(int count)
this sets the (local, reportable, and current) agent count.
|
private void |
setReadBuffers(byte[] data,
java.lang.String user)
this sets the data into the network read after recieve GLOBAL buffers.
|
void |
startRemoteAgent(java.lang.String ipa,
int port,
java.lang.String parameterList)
this sends a message to a remote Midwife that DEMANDS a new agent
start.
|
void |
template()
this method does nothing.
|
boolean |
testServerListening(java.lang.String host,
int port)
this is test for a listening server on a specific host IPA and port.
|
private void |
wait(int milliseconds)
this causes a wait in milliseconds using system resources.
|
final java.lang.String RESERVED
final java.lang.String STATUS_REQUESTED
final java.lang.String STATUS_REPORT
final java.lang.String BIRTH_REQUESTED
final java.lang.String BIRTH_DEMANDED
final java.lang.String ACKNOWLEGEMENT
final java.lang.String SAY_PARAMETER_LIST
final java.lang.String REQUEST_REFUSED
final int NONRESPONSIVE
private java.lang.String ipa
private int mwHealth
private int agentCount
private java.lang.String readBuffer
private java.lang.String loadStatus
private java.lang.String startAgent
private java.lang.String currentTask
private java.lang.String paramList
private static java.net.ServerSocket serverSocket
private static java.net.Socket socket
public MsgInterface(java.net.ServerSocket newServerSocket, int currentCount, java.lang.String hostIPA)
private void evaluateMidwifeMessage(java.io.InputStream inStream, java.io.OutputStream outStream)
private void flushBuffers(java.io.OutputStream outStream, java.io.InputStream inStream)
public java.lang.String getArguments(java.lang.String bufferContents)
public java.lang.String getTasking()
public java.lang.String getParamList()
public int getLoadingStatus(java.lang.String midwifeIPA, int port)
public void main()
private boolean receive(java.io.InputStream inStream, java.lang.String user)
private boolean send(java.lang.String botshaft, java.io.OutputStream outStream)
public void setAgentCount(int count)
private void setReadBuffers(byte[] data, java.lang.String user)
public void startRemoteAgent(java.lang.String ipa, int port, java.lang.String parameterList)
public boolean testServerListening(java.lang.String host, int port)
private void wait(int milliseconds)
public void template()