Uses of Class
fr.dyade.aaa.agent.Message

Packages that use Message

Package	Description
fr.dyade.aaa.agent

Uses of Message in fr.dyade.aaa.agent

Fields in fr.dyade.aaa.agent declared as Message

Modifier and Type	Field	Description
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	Engine.msg	The message in progress.
(package private) Message	HttpNetwork.NetworkInputStream.msg
(package private) Message	NGNetwork.CnxHandler.MessageInputStream.msg
(package private) Message	UDPNetwork.MessageAndIndex.msg	The sent message.
private Message	MessageSoftRef.ref	Reference for transient message, used to pin non persistent in memory.

Fields in fr.dyade.aaa.agent with type parameters of type Message

Modifier and Type	Field	Description
private SoftReference<Message>	MessageSoftRef.softRef	The SoftReference to the message, which permits to the message to be garbaged in response to memory demand.

Methods in fr.dyade.aaa.agent that return Message

Modifier and Type	Method	Description
(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	AgentEngineContext.createMessage(AgentId from, AgentId to, Notification not)	Creates a message.
Message	AgentEngineContextImpl.createMessage(AgentId from, AgentId to, Notification not)	Creates a message.
Message	MessageQueue.get()	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	MessageVector.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	MessageSoftList.getAck()	Returns the acknowledge waiting to be sent if present.
Message	MessageSoftList.getFirst()	Returns the first non expired message waiting to be sent.
(package private) Message	HttpNetwork.NetworkInputStream.getMessage()
Message	MessageSoftRef.getMessage()	Returns this reference message's referent.
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(String name)	Restores the object state from the persistent storage.
Message	MessageSoftRef.loadMessage()	Returns the message to which this reference refers, loading it from disk if the message has been swapped out.
Message	MessageSoftList.MessageSoftIterator.next()
Message	NGNetwork.MessageVector.nextMessage()
Message	MessageQueue.pop()	Removes the message at the top of this queue.
Message	MessageVector.pop()	Removes the message at the top of this queue.
(package private) Message	NGNetwork.CnxHandler.MessageInputStream.readHeader()
protected Message	MessageInputStream.readMessage()	Reads the message from this input stream.
(package private) Message	NGNetwork.CnxHandler.MessageInputStream.readMessage()
(package private) Message	SimpleNetwork.NetworkInputStream.readMessage(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

Modifier and Type	Method	Description
void	MessageSoftList.addMessage(Message msg)	Adds a message at the end of the list.
void	NGNetwork.MessageVector.addMessage(Message msg)	Adds the specified component to the end of this vector, increasing its size by one.
void	AgentEngineContext.channelPost(Message msg)	Posts a message in the channel.
void	AgentEngineContextImpl.channelPost(Message msg)	Posts a message in the channel.
protected void	Network.channelPostAndValidate(Message msg)
void	AgentEngineContext.checkMessageFrom(Message msg)	Checks the message 'from'.
void	AgentEngineContextImpl.checkMessageFrom(Message msg)	Checks the message 'from'.
int	MessageSoftList.MessageComparator.compare(Message o1, Message o2)
void	AgentEngineContext.deleteMessage(Message msg)	Deletes and frees the specified message.
void	AgentEngineContextImpl.deleteMessage(Message msg)	Deletes and frees the specified message.
protected void	Network.deleteMessage(Message msg)
protected void	Network.deliver(Message msg)	Try to deliver the received message to the right consumer.
protected short	Network.getMessageDest(Message msg)
protected short	Network.getMessageSource(Message msg)
protected int	HttpNetwork.handle(Message msgout, HttpNetwork.NetworkInputStream nis)
void	Engine.insert(Message msg)	Insert a message in the MessageQueue.
void	MessageConsumer.insert(Message msg)	Insert a message in the MessageQueue.
void	MessageQueue.insert(Message item, MessageComparator comparator)	Insert a message in the queue, it should only be used during initialization for restoring the queue state.
void	MessageVector.insert(Message item, MessageComparator comparator)	Insert a message in the queue, it should only be used during initialization for restoring the queue state.
void	Network.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.
boolean	Engine.isPrior(Message m1, Message m2)
boolean	MessageComparator.isPrior(Message m1, Message m2)	Compares the 2 messages for time ordering.
boolean	Network.isPrior(Message m1, Message m2)
(package private) static void	Channel.post(Message msg)	Adds a message in "ready to deliver" list of right consumer.
void	Engine.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	Network.post(Message msg)	Adds a message in "ready to deliver" list.
(package private) static void	Channel.postAndValidate(Message msg)
void	Engine.postAndValidate(Message msg)	Posts a message and validates it at the same time.
void	MessageConsumer.postAndValidate(Message msg)	Posts a message and validates it at the same time.
void	Network.postAndValidate(Message msg)	Posts and validates a message.
protected void	Network.postMessage(Message msg)
void	BatchNetworkItf.prepareMessage(Message message)
protected void	Network.prepareMessage(Message msg)
protected void	Network.prepareMessageWithoutStamp(Message msg)
void	MessageQueue.push(Message item)	Pushes a message onto the bottom of this queue.
void	MessageVector.push(Message item)	Pushes a message onto the bottom of this queue.
void	MessageQueue.pushAndValidate(Message item)	Pushes a message and validates it at the same time.
void	MessageVector.pushAndValidate(Message item)	Pushes and validates a message.
protected void	MessageInputStream.readMessageHeader(Message msg)	Reads the message header data from the buffer.
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	NGNetwork.CnxHandler.send(Message msg)
(package private) void	PoolNetwork.Sender.send(Message msg)
(package private) void	SimpleNetwork.NetServerOut.send(Socket socket, Message msg, long currentTimeMillis)
protected void	HttpNetwork.sendReply(Message msg, OutputStream os, HttpNetwork.NetworkOutputStream nos, int ack, long currentTimeMillis)
protected void	HttpNetwork.sendRequest(Message msg, OutputStream os, HttpNetwork.NetworkOutputStream nos, int ack, long currentTimeMillis)
void	MessageSoftList.setAck(Message ack)	Sets the next ack to send.
protected void	Network.setMessageSource(Message msg, short source)
void	MessageSoftList.setSent(Message msg)	Mark specified message as sent (ie waiting for an ack).
protected void	Engine.stamp(Message msg)	Sets the stamp of the given message.
void	AgentEngineContext.stampAndSave(Message msg, int stamp)	Stamps and saves the specified message.
void	AgentEngineContextImpl.stampAndSave(Message msg, int stamp)	Stamps and saves the specified message.
void	BatchNetworkItf.validateMessage(Message message)
(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	NGNetwork.CnxHandler.MessageOutputStream.writeMessage(Message msg)
(package private) void	SimpleNetwork.NetworkOutputStream.writeMessage(OutputStream os, Message msg, long currentTimeMillis)	Writes a message to the output stream of the socket.
(package private) void	UDPNetwork.DatagramOutputStream.writeMessage(UDPNetwork.ServerInfo serverInfo, SocketAddress addr, int startIndex, Message msg, long currentTimeMillis)
(package private) void	UDPNetwork.DatagramOutputStream.writeMessage(SocketAddress addr, 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

Constructor	Description
MessageAndIndex(Message msg, int index, int size)
MessageSoftRef(Message msg)