|
Joram ${version} | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.mom.dest.DestinationImpl
org.objectweb.joram.mom.dest.QueueImpl
org.objectweb.joram.mom.dest.DeadMQueueImpl
The DeadMQueueImpl
class implements the MOM dead message queue
behaviour, basically storing dead messages and delivering them upon clients
requests.
Field Summary |
Fields inherited from class org.objectweb.joram.mom.dest.QueueImpl |
arrivalsCounter, consumers, contexts, deliveredMsgs, messages, nbMaxMsg, receiving, requests |
Fields inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
_rights, clients, creationDate, destId, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSendToDMQSinceCreation, READ, READWRITE, WRITE |
Constructor Summary | |
DeadMQueueImpl(fr.dyade.aaa.agent.AgentId destId,
fr.dyade.aaa.agent.AgentId adminId)
Constructs a DeadMQueueImpl instance. |
Method Summary | |
protected void |
deliverMessages(int index)
Overrides this QueueImpl method; delivered messages are not
kept for acknowledgement or denying; validity of messages is
not checked and message fields are not updated; also, no sending to
any DMQ. |
protected void |
doProcess(fr.dyade.aaa.agent.UnknownAgent uA)
Overrides this QueueImpl method; if the sent notification
was a QueueMsgReply instance, putting the sent message back
in queue. |
protected void |
doReact(fr.dyade.aaa.agent.AgentId from,
AcknowledgeRequest not)
Overrides this QueueImpl method;
AcknowledgeRequest requests are actually not processed
in dead message queues. |
protected void |
doReact(fr.dyade.aaa.agent.AgentId from,
BrowseRequest not)
Overrides this QueueImpl method; messages matching the
request's selector are actually sent as a reply; no cleaning nor DMQ
sending is done. |
protected void |
doReact(fr.dyade.aaa.agent.AgentId from,
ClientMessages not)
Overrides this DestinationImpl method; the messages carried
by the ClientMessages instance are stored in their arrival
order, WRITE right is not checked. |
protected void |
doReact(fr.dyade.aaa.agent.AgentId from,
DenyRequest not)
Overrides this QueueImpl method;
DenyRequest requests are actually not processed
in dead message queues. |
protected void |
doReact(fr.dyade.aaa.agent.AgentId from,
SetDMQRequest req)
Overrides this DestinationImpl method; this request is
not expected by a dead message queue. |
protected void |
doReact(fr.dyade.aaa.agent.AgentId from,
SetThreshRequest req)
Overrides this QueueImpl method; this request is
not expected by a dead message queue. |
static java.lang.Integer |
getDefaultThreshold()
Static method returning the default threshold. |
static fr.dyade.aaa.agent.AgentId |
getId()
Static method returning the default DMQ identifier. |
protected void |
sendToDMQ(java.util.Vector deadMessages,
fr.dyade.aaa.agent.AgentId dmqId)
Overwrites this DestinationImpl method so that no messages
may be sent by the DMQ to itself. |
java.lang.String |
toString()
Returns a string representation of this destination. |
Methods inherited from class org.objectweb.joram.mom.dest.QueueImpl |
doProcess, doProcess, doProcess, doReact, doReact, doReact, doReact, doReact, doReact, doReact, getDeliveredMessageCount, getMessageCounter, getNbMaxMsg, getPendingMessageCount, getThreshold, getWaitingRequestCount, isUndeliverable, messageDelivered, messageRemoved, react, readBag, setNbMaxMsg, setThreshold, specialProcess, storeMessage, writeBag |
Methods inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
canBeDeleted, doReact, doReact, doReact, doReact, doReact, doReact, doReact, doReact, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getNbMsgsDeliverSinceCreation, getNbMsgsReceiveSinceCreation, getNbMsgsSendToDMQSinceCreation, getRight, getRights, isAdministrator, isFreeReading, isFreeWriting, isReader, isWriter, processSetRight, sendToDMQ, setFreeReading, setFreeWriting, specialAdminProcess |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.objectweb.joram.mom.dest.DestinationImplMBean |
getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getNbMsgsDeliverSinceCreation, getNbMsgsReceiveSinceCreation, getNbMsgsSendToDMQSinceCreation, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting |
Constructor Detail |
public DeadMQueueImpl(fr.dyade.aaa.agent.AgentId destId, fr.dyade.aaa.agent.AgentId adminId)
DeadMQueueImpl
instance.
destId
- Identifier of the agent hosting the queue.adminId
- Identifier of the administrator of the queue.Method Detail |
public java.lang.String toString()
QueueImpl
toString
in interface DestinationImplMBean
toString
in class QueueImpl
public static fr.dyade.aaa.agent.AgentId getId()
public static java.lang.Integer getDefaultThreshold()
protected void doReact(fr.dyade.aaa.agent.AgentId from, SetDMQRequest req) throws AccessException
DestinationImpl
method; this request is
not expected by a dead message queue.
doReact
in class DestinationImpl
AccessException
- Not thrown.protected void doReact(fr.dyade.aaa.agent.AgentId from, ClientMessages not) throws AccessException
DestinationImpl
method; the messages carried
by the ClientMessages
instance are stored in their arrival
order, WRITE right is not checked.
doReact
in class DestinationImpl
AccessException
- Never thrown.protected void doReact(fr.dyade.aaa.agent.AgentId from, SetThreshRequest req) throws AccessException
QueueImpl
method; this request is
not expected by a dead message queue.
doReact
in class QueueImpl
AccessException
- Not thrown.protected void doReact(fr.dyade.aaa.agent.AgentId from, BrowseRequest not) throws AccessException
QueueImpl
method; messages matching the
request's selector are actually sent as a reply; no cleaning nor DMQ
sending is done.
doReact
in class QueueImpl
AccessException
- If the requester is not a reader.protected void doReact(fr.dyade.aaa.agent.AgentId from, AcknowledgeRequest not)
QueueImpl
method;
AcknowledgeRequest
requests are actually not processed
in dead message queues.
doReact
in class QueueImpl
protected void doReact(fr.dyade.aaa.agent.AgentId from, DenyRequest not)
QueueImpl
method;
DenyRequest
requests are actually not processed
in dead message queues.
doReact
in class QueueImpl
protected void doProcess(fr.dyade.aaa.agent.UnknownAgent uA)
QueueImpl
method; if the sent notification
was a QueueMsgReply
instance, putting the sent message back
in queue.
doProcess
in class QueueImpl
protected void deliverMessages(int index)
QueueImpl
method; delivered messages are not
kept for acknowledgement or denying; validity of messages is
not checked and message fields are not updated; also, no sending to
any DMQ.
deliverMessages
in class QueueImpl
protected void sendToDMQ(java.util.Vector deadMessages, fr.dyade.aaa.agent.AgentId dmqId)
DestinationImpl
method so that no messages
may be sent by the DMQ to itself.
|
Joram ${version} | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |