|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Message | |
---|---|
fr.dyade.aaa.agent |
Uses of Message in fr.dyade.aaa.agent |
---|
Fields in fr.dyade.aaa.agent declared as Message | |
---|---|
private Message |
MessageSoftList.ack
Current ack message which will be sent in priority. |
private Message[] |
NGNetwork.MessageVector.elementData
The array buffer into which the components of the vector are stored. |
(package private) Message |
UDPNetwork.MessageAndIndex.msg
The sent message. |
(package private) Message |
NGNetwork.CnxHandler.MessageInputStream.msg
|
(package private) Message |
HttpNetwork.NetworkInputStream.msg
|
(package private) Message |
Engine.msg
The message in progress. |
private Message |
MessageSoftRef.ref
Reference for transient message, used to pin non persistent in memory. |
Methods in fr.dyade.aaa.agent that return Message | |
---|---|
(package private) static Message |
Message.alloc()
Allocates a message from the pool. |
(package private) static Message |
Message.alloc(AgentId from,
AgentId to,
Notification not)
Allocates a message from the pool. |
Message |
MessageVector.get()
Looks at the message at the top of this queue without removing it from the queue. |
Message |
MessageQueue.get()
Looks at the message at the top of this queue without removing it from the queue. |
Message |
MessageVector.get(long timeout)
Looks at the message at the top of this queue without removing it from the queue. |
Message |
MessageQueue.get(long timeout)
Looks at the message at the top of this queue without removing it from the queue. |
Message |
MessageSoftList.getAck()
Returns the acknowledge waiting to be sent if present. |
Message |
MessageSoftList.getFirst()
Returns the first non expired message waiting to be sent. |
Message |
MessageSoftRef.getMessage()
Returns this reference message's referent. |
(package private) Message |
HttpNetwork.NetworkInputStream.getMessage()
|
private Message |
MessageVector.getMessageAt(int index)
Returns the message at the specified index. |
Message |
MessageVector.getMessageTo(short to)
Looks at the first message of this queue where the destination server is the specified one. |
(package private) static Message |
Message.load(java.lang.String name)
Restores the object state from the persistent storage. |
Message |
MessageSoftRef.loadMessage()
Loads from disk this reference message's referent if the message has been swapped out. |
Message |
NGNetwork.MessageVector.nextMessage()
|
Message |
MessageVector.pop()
Removes the message at the top of this queue. |
Message |
MessageQueue.pop()
Removes the message at the top of this queue. |
(package private) Message |
NGNetwork.CnxHandler.MessageInputStream.readHeader()
|
(package private) Message |
NGNetwork.CnxHandler.MessageInputStream.readMessage()
|
protected Message |
MessageInputStream.readMessage()
Reads the message from this input stream. |
(package private) Message |
SimpleNetwork.NetworkInputStream.readMessage(java.io.InputStream is)
Reads the message from the input stream. |
(package private) Message |
MessageVector.removeExpired(long currentTimeMillis)
Removes the first messages with a timestamp less than the specified one. |
Message |
NGNetwork.MessageVector.removeMessage(int stamp)
Removes a message specified by its stamp. |
private Message |
MessageSoftList.selectFirst()
|
Methods in fr.dyade.aaa.agent with parameters of type Message | |
---|---|
void |
NGNetwork.MessageVector.addMessage(Message msg)
Adds the specified component to the end of this vector, increasing its size by one. |
void |
MessageSoftList.addMessage(Message msg)
Adds a message at the end of the list. |
int |
MessageSoftList.MessageComparator.compare(Message o1,
Message o2)
|
protected void |
Network.deliver(Message msg)
Try to deliver the received message to the right consumer. |
protected int |
HttpNetwork.handle(Message msgout,
HttpNetwork.NetworkInputStream nis)
|
void |
Network.insert(Message msg)
Insert a message in the MessageQueue . |
void |
MessageVector.insert(Message item)
Insert a message in the queue, it should only be used during initialization for restoring the queue state. |
void |
MessageQueue.insert(Message item)
Insert a message in the queue, it should only be used during initialization for restoring the queue state. |
void |
MessageConsumer.insert(Message msg)
Insert a message in the MessageQueue . |
void |
Engine.insert(Message msg)
Insert a message in the MessageQueue . |
private void |
MessageVector.insertMessageAt(Message item,
int index)
Inserts the specified message to this MessageVector at
the specified index. |
void |
Network.post(Message msg)
Adds a message in "ready to deliver" list. |
void |
MessageConsumer.post(Message msg)
Adds a message in "ready to deliver" list. |
void |
HAEngine.post(Message msg)
Adds a message in "ready to deliver" list. |
void |
Engine.post(Message msg)
Adds a message in "ready to deliver" list. |
(package private) static void |
Channel.post(Message msg)
Adds a message in "ready to deliver" list of right consumer. |
void |
MessageVector.push(Message item)
Pushes a message onto the bottom of this queue. |
void |
MessageQueue.push(Message item)
Pushes a message onto the bottom of this queue. |
protected void |
MessageInputStream.readMessageHeader(Message msg)
Reads the message header data from the buffer. |
(package private) void |
HAEngine.receiveFromJGroups(Message msg)
|
private void |
MessageSoftList.removeExpired(Message msg)
Removes the expired message, if needed an ExpiredNot is sent to the deadNotificationAgentId specified. |
(package private) void |
MessageVector.removeMessage(Message msg)
Removes the specified message from the queue if exists. |
(package private) void |
PoolNetwork.Sender.send(Message msg)
|
(package private) void |
NGNetwork.CnxHandler.send(Message msg)
|
(package private) void |
SimpleNetwork.NetServerOut.send(java.net.Socket socket,
Message msg,
long currentTimeMillis)
|
protected void |
HttpNetwork.sendReply(Message msg,
java.io.OutputStream os,
HttpNetwork.NetworkOutputStream nos,
int ack,
long currentTimeMillis)
|
protected void |
HttpNetwork.sendRequest(Message msg,
java.io.OutputStream os,
HttpNetwork.NetworkOutputStream nos,
int ack,
long currentTimeMillis)
|
void |
MessageSoftList.setAck(Message ack)
Sets the next ack to send. |
void |
MessageSoftList.setSent(Message msg)
Mark specified message as sent (ie waiting for an ack). |
protected void |
Engine.stamp(Message msg)
|
(package private) void |
NGNetwork.CnxHandler.MessageOutputStream.writeMessage(Message msg)
|
(package private) void |
HttpNetwork.NetworkOutputStream.writeMessage(Message msg,
int ack,
long currentTimeMillis)
|
protected void |
MessageOutputStream.writeMessage(Message msg,
long time)
Writes a message to this output stream. |
(package private) void |
SimpleNetwork.NetworkOutputStream.writeMessage(java.io.OutputStream os,
Message msg,
long currentTimeMillis)
Writes a message to the output stream of the socket. |
(package private) void |
UDPNetwork.DatagramOutputStream.writeMessage(java.net.SocketAddress addr,
Message msg,
long currentTimeMillis)
|
(package private) void |
UDPNetwork.DatagramOutputStream.writeMessage(UDPNetwork.ServerInfo serverInfo,
java.net.SocketAddress addr,
int startIndex,
Message msg,
long currentTimeMillis)
|
protected void |
MessageOutputStream.writeMessageHeader(Message msg)
Writes the message header data to the buffer. |
Constructors in fr.dyade.aaa.agent with parameters of type Message | |
---|---|
JGroupsAckMsg(Message message)
|
|
MessageSoftRef(Message msg)
|
|
UDPNetwork.MessageAndIndex(Message msg,
int index,
int size)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |