public class SchedulerQueue extends Queue
Queue.QueueFactory
Modifier and Type | Field and Description |
---|---|
static org.objectweb.util.monolog.api.Logger |
logger |
static String |
SCHEDULE_DATE |
static String |
SCHEDULED |
private Scheduler |
scheduler |
private static long |
serialVersionUID
define serialVersionUID for interoperability
|
ARRIVAL_STATE_PREFIX, arrivalState, DELIVERY_TABLE_PREFIX, DELIVERY_TIME_TABLE_PREFIX, deliveryTable, deliveryTimeTable, logmsg, messages, nbMaxMsg, nbMsgsDeniedSinceCreation, receiving, REDELIVERY_DELAY, requests
_rights, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, task, WAKEUP_PERIOD, WRITE
agentProfiling, emptyString, fixed, logmon
BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE
Constructor and Description |
---|
SchedulerQueue() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
checkDelivery(Message msg)
Returns true if conditions are ok to deliver the message.
|
private void |
condition(SchedulerQueueNot not) |
int |
getEncodableClassId()
Enables the sub classes not to implement this method.
|
private static long |
getScheduleDate(Message msg) |
void |
initialize(boolean firstTime)
Initializes the destination.
|
void |
postProcess(ClientMessages not)
This method is needed to add processing after the standard handling.
|
void |
react(AgentId from,
Notification not)
Distributes the received notifications to the appropriate reactions.
|
abortReceiveRequest, acknowledgeRequest, addClientMessages, addMessage, agentSave, browseRequest, cleanPendingMessage, cleanPendingMessage, cleanWaitingRequest, cleanWaitingRequest, decode, deliverMessages, denyRequest, doClientMessages, doDeleteNot, doRightRequest, doUnknownAgent, encode, finalize, getClientMessages, getConsumerLoad, getDefaultDMQId, getDefaultRedeliveryDelay, getDefaultThreshold, getDeliveredMessageCount, getDeliveryTimeMessageCount, getEncodedSize, getMessage, getMessages, getMessagesView, getMsgTxPrefix, getNbMaxMsg, getNbMsgsDeliverSinceCreation, getNbMsgsDeniedSinceCreation, getNbMsgsReceiveSinceCreation, getPendingMessageCount, getProducerLoad, getQueueMessage, getRedeliveryDelay, getStats, getThreshold, getType, getWaitingRequestCount, handleAdminRequestNot, handleExpiredNot, isSyncExceptionOnFullDest, isUndeliverable, isValidJMXAttribute, messageDelivered, messageRemoved, receiveRequest, removeMessages, setDefaultRedeliveryDelay, setMsgTxName, setNbMaxMsg, setProperties, setRedeliveryDelay, setSyncExceptionOnFullDest, setThreshold, storeMessage, storeMessageHeader, toString, wakeUpNot
agentFinalize, agentInitialize, clientMessages, delete, deleteNot, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQAgentId, getDMQId, getJMXStatistics, getMBeanName, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getRights, handleDeniedMessage, interceptorsAvailable, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isWriter, preProcess, processAdminCommand, processInterceptors, processSetRight, processStartHandler, processStopHandler, replyToTopic, requestGroupNot, setAdminId, setFreeReading, setFreeWriting, setPeriod, setRight, unknownAgent
delete, delete, deploy, deploy, getAgentId, getCommitTime, getId, getLogTopic, getName, getReactNb, getReactTime, hasName, isAgentProfiling, isDeployed, isFixed, isUpdated, needToBeCommited, resetCommitTime, resetReactTime, resetTimer, save, sendTo, sendTo, sendTo, setAgentProfiling, setName, setNoSave, setSave
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod
getAgentId, getCommitTime, getReactNb, getReactTime, isAgentProfiling, isFixed, resetCommitTime, resetReactTime, resetTimer, setAgentProfiling
private static final long serialVersionUID
public static org.objectweb.util.monolog.api.Logger logger
public static final String SCHEDULE_DATE
public static final String SCHEDULED
private Scheduler scheduler
public void initialize(boolean firstTime) throws Exception
initialize
in class Queue
firstTime
- true when first called by the factoryException
public void react(AgentId from, Notification not) throws Exception
Queue
public void postProcess(ClientMessages not)
Destination
Queue
and Topic
.
The incoming messages can be modified or deleted during the processing.postProcess
in class Destination
not
- The incoming messages.private static long getScheduleDate(Message msg)
private void condition(SchedulerQueueNot not)
protected boolean checkDelivery(Message msg)
Queue
checkDelivery
in class Queue
public int getEncodableClassId()
Agent
getEncodableClassId
in interface Encodable
getEncodableClassId
in class Queue
Copyright © 2016 ScalAgent D.T.. All Rights Reserved.