Package | Description |
---|---|
fr.dyade.aaa.agent |
Modifier and Type | Field and 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 |
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.
|
Modifier and Type | Field and Description |
---|---|
private SoftReference<Message> |
MessageSoftRef.softRef
The SoftReference to the message, which permits to the message to be
garbaged in response to memory demand.
|
Modifier and Type | Method and 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 |
AgentEngineContextImpl.createMessage(AgentId from,
AgentId to,
Notification not)
Creates a message.
|
Message |
AgentEngineContext.createMessage(AgentId from,
AgentId to,
Notification not)
Creates a message.
|
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(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 |
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(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() |
Modifier and Type | Method and Description |
---|---|
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.
|
void |
AgentEngineContextImpl.channelPost(Message msg)
Posts a message in the channel.
|
void |
AgentEngineContext.channelPost(Message msg)
Posts a message in the channel.
|
protected void |
Network.channelPostAndValidate(Message msg) |
void |
AgentEngineContextImpl.checkMessageFrom(Message msg)
Checks the message 'from'.
|
void |
AgentEngineContext.checkMessageFrom(Message msg)
Checks the message 'from'.
|
int |
MessageSoftList.MessageComparator.compare(Message o1,
Message o2) |
protected void |
Network.deleteMessage(Message msg) |
void |
AgentEngineContextImpl.deleteMessage(Message msg)
Deletes and frees the specified message.
|
void |
AgentEngineContext.deleteMessage(Message msg)
Deletes and frees the specified message.
|
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 |
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 |
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 |
Network.postAndValidate(Message msg)
Posts and validates a message.
|
void |
MessageConsumer.postAndValidate(Message msg)
Posts a message and validates it at the same time.
|
void |
Engine.postAndValidate(Message msg)
Posts a message and validates it at the same time.
|
(package private) static void |
Channel.postAndValidate(Message msg) |
protected void |
Network.postMessage(Message msg) |
protected void |
Network.prepareMessage(Message msg) |
protected void |
Network.prepareMessageWithoutStamp(Message msg) |
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.
|
void |
MessageVector.pushAndValidate(Message item)
Pushes and validates a message.
|
void |
MessageQueue.pushAndValidate(Message item)
Pushes a message and validates it at the same time.
|
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 |
PoolNetwork.Sender.send(Message msg) |
(package private) void |
NGNetwork.CnxHandler.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) |
void |
AgentEngineContextImpl.stampAndSave(Message msg,
int stamp)
Stamps and saves the specified message.
|
void |
AgentEngineContext.stampAndSave(Message msg,
int stamp)
Stamps and saves the specified message.
|
(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(OutputStream os,
Message msg,
long currentTimeMillis)
Writes a message to the output stream of the socket.
|
(package private) void |
UDPNetwork.DatagramOutputStream.writeMessage(SocketAddress addr,
Message msg,
long currentTimeMillis) |
(package private) void |
UDPNetwork.DatagramOutputStream.writeMessage(UDPNetwork.ServerInfo serverInfo,
SocketAddress addr,
int startIndex,
Message msg,
long currentTimeMillis) |
protected void |
MessageOutputStream.writeMessageHeader(Message msg)
Writes the message header data to the buffer.
|
Constructor and Description |
---|
MessageSoftRef(Message msg) |
UDPNetwork.MessageAndIndex(Message msg,
int index,
int size) |
Copyright © 2016 ScalAgent D.T.. All Rights Reserved.