public class DistributionTopic extends Topic implements DistributionTopicMBean
DistributionQueue
class implements the MOM distribution topic
behavior, delivering messages via the DistributionModule
.Modifier and Type | Field and Description |
---|---|
private String |
distributionClassName
The acquisition class name.
|
private DistributionDaemon |
distributionDaemon |
private DistributionModule |
distributionModule |
private boolean |
isAsyncDistribution
Tells if daemon distribution is active.
|
static org.objectweb.util.monolog.api.Logger |
logger |
private Properties |
properties |
private static long |
serialVersionUID
define serialVersionUID for interoperability
|
fatherId, friends, nbMsgsReceiveSinceCreation, selectors, subscribers
_rights, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, strbuf, strictCounters, task, temporary, 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 |
---|
DistributionTopic() |
Modifier and Type | Method and Description |
---|---|
void |
agentFinalize(boolean lastTime)
Finalizes the agent before it is garbaged.
|
String |
dumpProperties() |
void |
initialize(boolean firstTime)
Initializes the destination.
|
private boolean |
isAsyncDistribution(Properties properties) |
protected void |
postProcess(ClientMessages msgs)
This method is needed to add processing after the standard handling.
|
ClientMessages |
preProcess(AgentId from,
ClientMessages cm)
This method is needed to add processing before the standard handling.
|
void |
setProperties(Properties properties,
boolean firstTime)
Configures a
DistributionTopic instance. |
String |
toString()
Returns a string representation of this destination.
|
void |
wakeUpNot(WakeUpNot not) |
clusterJoin, clusterJoinAck, createTopicForward, doClientMessages, doDeleteNot, doRightRequest, doUnknownAgent, finalize, forwardMessages, forwardMessages, getClusterElements, getNbMsgsReceiveSinceCreation, getNumberOfSubscribers, getStats, getSubscriberIds, getTxName, getType, handleAdminRequestNot, postSubscribe, postUnsubscribe, preSubscribe, preUnsubscribe, processMessages, react, sendToCluster, subscribeRequest, topicForwardNot, unsubscribeRequest
agentInitialize, clientMessages, decode, delete, deleteNot, encode, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQAgentId, getDMQId, getEncodedSize, getJMXStatistics, getMBeanName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getRights, handleDeniedMessage, interceptorsAvailable, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isValidJMXAttribute, isWriter, processAdminCommand, processInterceptors, processPause, processSetRight, processStartHandler, processStopHandler, replyToTopic, requestGroupNot, setAdminId, setFreeReading, setFreeWriting, setPeriod, setRight, unknownAgent
agentSave, delete, delete, deploy, deploy, getAgentId, getCommitTime, getEncodableClassId, getId, getLogTopic, getName, getReactNb, getReactTime, hasName, incWorkInProgress, 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
getNumberOfSubscribers, getSubscriberIds
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsReceiveSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getType, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod
getAgentId, getCommitTime, getReactNb, getReactTime, isAgentProfiling, isFixed, resetCommitTime, resetReactTime, resetTimer, setAgentProfiling
getClusterElements
public static org.objectweb.util.monolog.api.Logger logger
private static final long serialVersionUID
private transient DistributionModule distributionModule
private String distributionClassName
private Properties properties
private transient DistributionDaemon distributionDaemon
private boolean isAsyncDistribution
public String dumpProperties()
dumpProperties
in interface DistributionTopicMBean
public void setProperties(Properties properties, boolean firstTime) throws Exception
DistributionTopic
instance.setProperties
in class Destination
properties
- The initial set of properties.Exception
private boolean isAsyncDistribution(Properties properties)
public void initialize(boolean firstTime)
Topic
initialize
in class Topic
firstTime
- true when first called by the factorypublic void agentFinalize(boolean lastTime)
Destination
agentFinalize
in class Destination
lastTime
- true if the destination is deletedpublic ClientMessages preProcess(AgentId from, ClientMessages cm)
Destination
Queue
and Topic
.
The incoming messages can be modified or deleted during the processing.preProcess
in class Destination
from
- The sender of the messagecm
- The incoming messages.protected void postProcess(ClientMessages msgs)
Destination
Queue
and Topic
.
The incoming messages can be modified or deleted during the processing.postProcess
in class Destination
msgs
- The incoming messages.public String toString()
Topic
toString
in interface AgentMBean
toString
in interface DestinationMBean
toString
in class Topic
Copyright © 2021 ScalAgent D.T.. All rights reserved.