|
||||||||||
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, persistenceModule, receiving, requests |
Fields inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
adminId, clients, destId, dmqId, freeReading, freeWriting, READ, READWRITE, WRITE |
Constructor Summary | |
DeadMQueueImpl(AgentId destId,
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(UnknownAgent uA)
Overrides this QueueImpl method; if the sent notification
was a QueueMsgReply instance, putting the sent message back
in queue. |
protected void |
doReact(AgentId from,
AcknowledgeRequest not)
Overrides this QueueImpl method;
AcknowledgeRequest requests are actually not processed
in dead message queues. |
protected void |
doReact(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(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(AgentId from,
DenyRequest not)
Overrides this QueueImpl method;
DenyRequest requests are actually not processed
in dead message queues. |
protected void |
doReact(AgentId from,
SetDMQRequest req)
Overrides this DestinationImpl method; this request is
not expected by a dead message queue. |
protected void |
doReact(AgentId from,
SetThreshRequest req)
Overrides this QueueImpl method; this request is
not expected by a dead message queue. |
static AgentId |
getId()
Static method returning the default DMQ identifier. |
static java.lang.Integer |
getThreshold()
Static method returning the default threshold. |
protected void |
sendToDMQ(java.util.Vector deadMessages,
AgentId dmqId)
Overwrites this DestinationImpl method so that no messages
may be sent by the DMQ to itself. |
java.lang.String |
toString()
|
Methods inherited from class org.objectweb.joram.mom.dest.QueueImpl |
doProcess, doProcess, doProcess, doReact, doReact, doReact, doReact, isUndeliverable, messageDelivered, messageRemoved, react, specialProcess, storeMessage |
Methods inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
canBeDeleted, doReact, doReact, doReact, doReact, doReact, doReact, doReact, isAdministrator, isReader, isWriter, processSetRight, sendToDMQ, specialAdminProcess |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public DeadMQueueImpl(AgentId destId, 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()
toString
in class QueueImpl
public static AgentId getId()
public static java.lang.Integer getThreshold()
protected void doReact(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(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(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(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(AgentId from, AcknowledgeRequest not)
QueueImpl
method;
AcknowledgeRequest
requests are actually not processed
in dead message queues.
doReact
in class QueueImpl
protected void doReact(AgentId from, DenyRequest not)
QueueImpl
method;
DenyRequest
requests are actually not processed
in dead message queues.
doReact
in class QueueImpl
protected void doProcess(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
index
- Index where starting to "browse" the requests.protected void sendToDMQ(java.util.Vector deadMessages, AgentId dmqId)
DestinationImpl
method so that no messages
may be sent by the DMQ to itself.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |