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

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)
           
 



Copyright © 2010 ScalAgent D.T.. All Rights Reserved.