|
|||||||||
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
public class QueueImpl
The QueueImpl
class implements the MOM queue behaviour,
basically storing messages and delivering them upon clients requests.
Field Summary | |
---|---|
protected long |
arrivalsCounter
Counter of messages arrivals. |
protected java.util.Hashtable |
consumers
Table keeping the messages' consumers identifiers. |
protected java.util.Hashtable |
contexts
Table keeping the messages' consumers contexts. |
(package private) static AgentId |
defaultDMQId
Static value holding the default DMQ identifier for a server. |
(package private) static int |
defaultThreshold
Static value holding the default threshold for a server. |
protected java.util.Hashtable |
deliveredMsgs
Table holding the delivered messages before acknowledgment. |
static org.objectweb.util.monolog.api.Logger |
logger
|
protected java.util.Vector |
messages
Vector holding the messages before delivery. |
(package private) java.lang.StringBuffer |
msgTxPrefix
|
(package private) int |
msgTxPrefixLength
|
protected int |
nbMaxMsg
nb Max of Message store in queue (-1 no limit). |
private int |
priority
Common priority value. |
protected boolean |
receiving
true if the queue is currently receiving messages. |
protected java.util.Vector |
requests
Vector holding the requests before reply or expiry. |
private boolean |
samePriorities
true if all the stored messages have the same priority. |
private static long |
serialVersionUID
define serialVersionUID for interoperability |
private int |
threshold
Threshold above which messages are considered as undeliverable because constantly denied; 0 stands for no threshold, -1 for value not set. |
Fields inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
---|
_rights, agent, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, strbuf, WAKEUP_PERIOD, WRITE |
Constructor Summary | |
---|---|
QueueImpl(AgentId adminId,
java.util.Properties prop)
Constructs a QueueImpl instance. |
Method Summary | |
---|---|
void |
abortReceiveRequest(AgentId from,
AbortReceiveRequest not)
|
private void |
acknowledge(java.lang.String msgId)
|
void |
acknowledgeRequest(AcknowledgeRequest not)
Method implementing the reaction to an AcknowledgeRequest
instance, requesting messages to be acknowledged. |
void |
addClientMessages(ClientMessages clientMsgs)
Adds the client messages in the queue. |
protected boolean |
addMessage(Message message)
Adds a message in the list of messages to deliver. |
void |
browseRequest(AgentId from,
BrowseRequest not)
Method implementing the queue reaction to a BrowseRequest
instance, requesting an enumeration of the messages on the queue. |
protected boolean |
checkDelivery(Message msg)
Returns true if conditions are ok to deliver the message. |
void |
cleanPendingMessage()
Removes all messages that the time-to-live is expired. |
protected DMQManager |
cleanPendingMessage(long currentTime)
Cleans the pending messages list. |
void |
cleanWaitingRequest()
Removes all request that the expiration time is expired. |
protected void |
cleanWaitingRequest(long currentTime)
Cleans the waiting request list. |
private void |
clearQueue(AgentId replyTo,
java.lang.String requestMsgId,
java.lang.String replyMsgId)
|
private void |
deleteQueueMessage(DeleteQueueMessage request,
AgentId replyTo,
java.lang.String requestMsgId,
java.lang.String replyMsgId)
|
protected void |
deliverMessages(int index)
Actually tries to answer the pending "receive" requests. |
void |
denyRequest(AgentId from,
DenyRequest not)
Method implementing the reaction to a DenyRequest
instance, requesting messages to be denied. |
protected void |
doClientMessages(AgentId from,
ClientMessages not)
Method specifically processing a ClientMessages instance. |
protected void |
doDeleteNot(DeleteNot not)
Method specifically processing a fr.dyade.aaa.agent.DeleteNot instance. |
protected void |
doRightRequest(AgentId user,
int right)
Method specifically processing a SetRightRequest instance. |
protected void |
doUnknownAgent(UnknownAgent uA)
Method specifically processing an UnknownAgent instance. |
protected ClientMessages |
getClientMessages(int nb,
java.lang.String selector,
boolean remove)
Get a client message contain nb messages. |
static AgentId |
getDefaultDMQId()
Static method returning the default DMQ identifier. |
static int |
getDefaultThreshold()
Static method returning the default threshold. |
int |
getDeliveredMessageCount()
Returns the number of messages delivered and waiting for acknowledge. |
javax.management.openmbean.CompositeData |
getMessage(java.lang.String msgId)
Returns the description of a particular pending message. |
javax.management.openmbean.TabularData |
getMessages()
Returns the description of all pending messages. |
private java.util.List |
getMessages(int nb,
java.lang.String selector,
boolean remove)
get messages, if it's possible. |
java.util.List |
getMessagesView()
Returns the description of all pending messages. |
private Message |
getMomMessage(java.lang.String msgId)
|
protected java.lang.StringBuffer |
getMsgTxPrefix()
|
int |
getNbMaxMsg()
Returns the maximum number of message for the destination. |
long |
getNbMsgsReceiveSinceCreation()
Returns the number of messages received since creation time of this destination. |
int |
getPendingMessageCount()
Returns the number of pending messages in the queue. |
private void |
getQueueMessage(GetQueueMessage request,
AgentId replyTo,
java.lang.String requestMsgId,
java.lang.String replyMsgId)
|
protected Message |
getQueueMessage(java.lang.String msgId,
boolean remove)
get mom message, delete if remove = true. |
private void |
getQueueMessageIds(AgentId replyTo,
java.lang.String requestMsgId,
java.lang.String replyMsgId)
|
int |
getThreshold()
Returns the threshold value of this queue, -1 if not set. |
int |
getWaitingRequestCount()
Returns the number of waiting requests in the queue. |
void |
handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not)
|
protected void |
handleExpiredNot(AgentId from,
ExpiredNot not)
|
void |
initialize(boolean firstTime)
Initializes the destination. |
protected boolean |
isUndeliverable(Message message)
Returns true if a given message is considered as undeliverable,
because its delivery count matches the queue's threshold, if any, or the
server's default threshold value (if any). |
protected boolean |
isValidJMXAttribute(java.lang.String attrName)
This method allows to exclude some JMX attribute of getJMXStatistics method. |
protected void |
messageDelivered(java.lang.String msgId)
call in deliverMessages just after forward(msg), overload this method to process a specific treatment. |
protected void |
messageRemoved(java.lang.String msgId)
call in deliverMessages just after a remove message (invalid), overload this method to process a specific treatment. |
void |
readBag(java.io.ObjectInputStream in)
|
void |
receiveRequest(AgentId from,
ReceiveRequest not)
Method implementing the reaction to a ReceiveRequest
instance, requesting a message. |
protected void |
setMsgTxName(Message msg)
|
void |
setNbMaxMsg(int nbMaxMsg)
Sets the maximum number of message for the destination. |
void |
setThreshold(int threshold)
Sets or unsets the threshold for this queue. |
protected void |
storeMessage(Message message)
Actually stores a message in the deliverables vector. |
protected void |
storeMessageHeader(Message message)
Actually stores a message header in the deliverables vector. |
java.lang.String |
toString()
Returns a string representation of this destination. |
void |
wakeUpNot(WakeUpNot not)
wake up, and cleans the queue. |
void |
writeBag(java.io.ObjectOutputStream out)
|
Methods inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
---|
canBeDeleted, clientMessages, delete, deleteNot, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQAgentId, getDMQId, getId, getJMXStatistics, getName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getRights, handleDeniedMessage, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isWriter, postProcess, preProcess, processSetRight, replyToTopic, requestGroupNot, setAgent, setFreeReading, setFreeWriting, setNoSave, setPeriod, setRight, setSave, specialAdminProcess, specialAdminRequest, unknownAgent |
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 |
---|
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod |
Field Detail |
---|
private static final long serialVersionUID
public static org.objectweb.util.monolog.api.Logger logger
static AgentId defaultDMQId
private int threshold
static int defaultThreshold
private boolean samePriorities
true
if all the stored messages have the same priority.
private int priority
protected java.util.Hashtable consumers
protected java.util.Hashtable contexts
protected long arrivalsCounter
protected java.util.Vector requests
protected transient boolean receiving
true
if the queue is currently receiving messages.
protected transient java.util.Vector messages
protected transient java.util.Hashtable deliveredMsgs
protected int nbMaxMsg
transient java.lang.StringBuffer msgTxPrefix
transient int msgTxPrefixLength
Constructor Detail |
---|
public QueueImpl(AgentId adminId, java.util.Properties prop)
QueueImpl
instance.
adminId
- Identifier of the administrator of the queue.prop
- The initial set of properties.Method Detail |
---|
public int getThreshold()
getThreshold
in interface QueueImplMBean
public void setThreshold(int threshold)
setThreshold
in interface QueueImplMBean
threshold
- The threshold value to be set (-1 for unsetting previous value).public static int getDefaultThreshold()
public static AgentId getDefaultDMQId()
public void cleanWaitingRequest()
cleanWaitingRequest
in interface QueueImplMBean
protected void cleanWaitingRequest(long currentTime)
currentTime
- The current time.public final int getWaitingRequestCount()
getWaitingRequestCount
in interface QueueImplMBean
public void cleanPendingMessage()
cleanPendingMessage
in interface QueueImplMBean
protected DMQManager cleanPendingMessage(long currentTime)
currentTime
- The current time.
DMQManager
which contains the expired messages.
null
if there wasn't any.public final int getPendingMessageCount()
getPendingMessageCount
in interface QueueImplMBean
public final int getDeliveredMessageCount()
getDeliveredMessageCount
in interface QueueImplMBean
public final long getNbMsgsReceiveSinceCreation()
DestinationImpl
getNbMsgsReceiveSinceCreation
in interface DestinationImplMBean
getNbMsgsReceiveSinceCreation
in class DestinationImpl
public final int getNbMaxMsg()
getNbMaxMsg
in interface QueueImplMBean
public void setNbMaxMsg(int nbMaxMsg)
setNbMaxMsg
in interface QueueImplMBean
nbMaxMsg
- the maximum number of message (-1 set no limit).public void initialize(boolean firstTime)
initialize
in class DestinationImpl
firstTime
- true when first called by the factorypublic java.lang.String toString()
toString
in interface DestinationImplMBean
toString
in class java.lang.Object
public void wakeUpNot(WakeUpNot not)
wakeUpNot
in class DestinationImpl
protected boolean isValidJMXAttribute(java.lang.String attrName)
isValidJMXAttribute
in class DestinationImpl
attrName
- name of attribute to test.
public void receiveRequest(AgentId from, ReceiveRequest not) throws AccessException
ReceiveRequest
instance, requesting a message.
This method stores the request and launches a delivery sequence.
AccessException
- If the sender is not a reader.public void browseRequest(AgentId from, BrowseRequest not) throws AccessException
BrowseRequest
instance, requesting an enumeration of the messages on the queue.
The method sends a BrowseReply
back to the client. Expired
messages are sent to the DMQ.
AccessException
- If the requester is not a reader.public void acknowledgeRequest(AcknowledgeRequest not)
AcknowledgeRequest
instance, requesting messages to be acknowledged.
private void acknowledge(java.lang.String msgId)
public void denyRequest(AgentId from, DenyRequest not)
DenyRequest
instance, requesting messages to be denied.
This method denies the messages and launches a delivery sequence. Messages considered as undeliverable are sent to the DMQ.
public void abortReceiveRequest(AgentId from, AbortReceiveRequest not)
public void handleAdminRequestNot(AgentId from, FwdAdminRequestNot not)
handleAdminRequestNot
in class DestinationImpl
DestinationImpl.handleAdminRequestNot(fr.dyade.aaa.agent.AgentId, org.objectweb.joram.mom.notifications.FwdAdminRequestNot)
private void getQueueMessageIds(AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
private void getQueueMessage(GetQueueMessage request, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
private void deleteQueueMessage(DeleteQueueMessage request, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
private void clearQueue(AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
protected void doRightRequest(AgentId user, int right)
SetRightRequest
instance.
When a reader is removed, and receive requests of this reader are still
on the queue, they are replied to by an ExceptionReply
.
doRightRequest
in class DestinationImpl
user
- The user about right modification.right
- The right modification.protected void doClientMessages(AgentId from, ClientMessages not)
ClientMessages
instance.
This method stores the messages and launches a delivery sequence.
doClientMessages
in class DestinationImpl
protected void doUnknownAgent(UnknownAgent uA)
UnknownAgent
instance.
The specific processing is done when a QueueMsgReply
was
sent to a requester which does not exist anymore. In that case, the
messages sent to this requester and not yet acknowledged are marked as
"denied" for delivery to an other requester, and a new delivery sequence
is launched. Messages considered as undeliverable are removed and sent to
the DMQ.
doUnknownAgent
in class DestinationImpl
protected void doDeleteNot(DeleteNot not)
fr.dyade.aaa.agent.DeleteNot
instance.
ExceptionReply
replies are sent to the pending receivers,
and the remaining messages are sent to the DMQ and deleted.
doDeleteNot
in class DestinationImpl
protected final java.lang.StringBuffer getMsgTxPrefix()
protected final void setMsgTxName(Message msg)
protected final void storeMessage(Message message)
message
- The message to store.protected final void storeMessageHeader(Message message)
message
- The message to store.protected final boolean addMessage(Message message)
message
- the message to add.
protected ClientMessages getClientMessages(int nb, java.lang.String selector, boolean remove)
nb
messages.
nb
- number of messages returned in ClientMessage.selector
- jms selectorremove
- delete all messages returned if true
private java.util.List getMessages(int nb, java.lang.String selector, boolean remove)
nb
- -1 return all messages.selector
- jms selector.
private Message getMomMessage(java.lang.String msgId)
protected Message getQueueMessage(java.lang.String msgId, boolean remove)
msgId
- message identificationremove
- if true delete message
public javax.management.openmbean.CompositeData getMessage(java.lang.String msgId) throws java.lang.Exception
getMessage
in interface QueueImplMBean
msgId
- The unique message's identifier.
java.lang.Exception
MessageJMXWrapper
public javax.management.openmbean.TabularData getMessages() throws java.lang.Exception
getMessages
in interface QueueImplMBean
java.lang.Exception
MessageJMXWrapper
public java.util.List getMessagesView()
QueueImplMBean
getMessagesView
in interface QueueImplMBean
protected void deliverMessages(int index)
The method may send QueueMsgReply
replies to clients.
index
- Index where starting to "browse" the requests.protected boolean checkDelivery(Message msg)
protected void messageDelivered(java.lang.String msgId)
protected void messageRemoved(java.lang.String msgId)
protected boolean isUndeliverable(Message message)
true
if a given message is considered as undeliverable,
because its delivery count matches the queue's threshold, if any, or the
server's default threshold value (if any).
public void addClientMessages(ClientMessages clientMsgs)
clientMsgs
- client message notification.public void readBag(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
public void writeBag(java.io.ObjectOutputStream out) throws java.io.IOException
java.io.IOException
protected void handleExpiredNot(AgentId from, ExpiredNot not)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |