org.objectweb.joram.mom.dest
Class DeadMQueueImpl
- java.io.Serializable
public class DeadMQueueImpl
The DeadMQueueImpl
class implements the MOM dead message queue
behaviour, basically storing dead messages and delivering them upon clients
requests.
- Serialized Form
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 Integer | getThreshold() - Static method returning the default threshold.
|
protected void | sendToDMQ(Vector deadMessages, AgentId dmqId) - Overwrites this
DestinationImpl method so that no messages
may be sent by the DMQ to itself.
|
String | toString()
|
deliverMessages , doProcess , doProcess , doProcess , doProcess , doReact , doReact , doReact , doReact , doReact , doReact , doReact , doReact , isUndeliverable , messageDelivered , messageRemoved , react , specialProcess , storeMessage , toString |
canBeDeleted , doReact , doReact , doReact , doReact , doReact , doReact , doReact , doReact , doReact , doReact , isAdministrator , isReader , isWriter , processSetRight , react , sendToDMQ , specialAdminProcess , specialProcess |
DeadMQueueImpl
public DeadMQueueImpl(AgentId destId,
AgentId adminId)
Constructs a DeadMQueueImpl
instance.
destId
- Identifier of the agent hosting the queue.adminId
- Identifier of the administrator of the queue.
deliverMessages
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.
- deliverMessages in interface QueueImpl
doProcess
protected void doProcess(UnknownAgent uA)
Overrides this QueueImpl
method; if the sent notification
was a QueueMsgReply
instance, putting the sent message back
in queue.
- doProcess in interface QueueImpl
doReact
protected void doReact(AgentId from,
AcknowledgeRequest not)
Overrides this QueueImpl
method;
AcknowledgeRequest
requests are actually not processed
in dead message queues.
- doReact in interface QueueImpl
doReact
protected void doReact(AgentId from,
BrowseRequest not)
throws AccessException
Overrides this QueueImpl
method; messages matching the
request's selector are actually sent as a reply; no cleaning nor DMQ
sending is done.
- doReact in interface QueueImpl
AccessException
- If the requester is not a reader.
doReact
protected void doReact(AgentId from,
DenyRequest not)
Overrides this QueueImpl
method;
DenyRequest
requests are actually not processed
in dead message queues.
- doReact in interface QueueImpl
getId
public static AgentId getId()
Static method returning the default DMQ identifier.
getThreshold
public static Integer getThreshold()
Static method returning the default threshold.
sendToDMQ
protected void sendToDMQ(Vector deadMessages,
AgentId dmqId)
Overwrites this DestinationImpl
method so that no messages
may be sent by the DMQ to itself.
toString
public String toString()
- toString in interface QueueImpl
Copyright B) 2004 Scalagent - All rights reserved