org.objectweb.joram.mom.dest
Class DistributionTopicImpl
java.lang.Object
org.objectweb.joram.mom.dest.DestinationImpl
org.objectweb.joram.mom.dest.TopicImpl
org.objectweb.joram.mom.dest.DistributionTopicImpl
- All Implemented Interfaces:
- java.io.Serializable, DestinationImplMBean, TopicImplMBean
public class DistributionTopicImpl
- extends TopicImpl
The DistributionQueueImpl
class implements the MOM distribution topic
behavior, delivering messages via the DistributionModule
.
- See Also:
- Serialized Form
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 |
Methods inherited from class org.objectweb.joram.mom.dest.TopicImpl |
clusterAck, clusterNot, clusterTest, doClientMessages, doDeleteNot, doRightRequest, doUnknownAgent, forwardMessages, getNbMsgsReceiveSinceCreation, getNumberOfSubscribers, getSubscriberIds, handleAdminRequestNot, postSubscribe, postUnsubscribe, preSubscribe, preUnsubscribe, processMessages, setAlreadySentLocally, subscribeRequest, topicForwardNot, unsubscribeRequest, wakeUpNot |
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, isValidJMXAttribute, isWriter, postProcess, 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 |
logger
public static org.objectweb.util.monolog.api.Logger logger
serialVersionUID
private static final long serialVersionUID
- define serialVersionUID for interoperability
- See Also:
- Constant Field Values
distributionModule
private transient DistributionModule distributionModule
properties
private java.util.Properties properties
DistributionTopicImpl
public DistributionTopicImpl(AgentId adminId,
java.util.Properties properties)
throws RequestException
- Constructs a
DistributionTopicImpl
instance.
- Parameters:
adminId
- Identifier of the administrator of the topic.prop
- The initial set of properties.
- Throws:
RequestException
initialize
public void initialize(boolean firstTime)
- Description copied from class:
TopicImpl
- Initializes the destination.
- Overrides:
initialize
in class TopicImpl
- Parameters:
firstTime
- true when first called by the factory
preProcess
public ClientMessages preProcess(AgentId from,
ClientMessages cm)
- Description copied from class:
DestinationImpl
- This method is needed to add processing before the standard handling. It
is used in subclass of
QueueImpl
and TopicImpl
.
The incoming messages can be modified or deleted during the processing.
- Overrides:
preProcess
in class DestinationImpl
- Parameters:
from
- The sender of the messagecm
- The incoming messages.
- Returns:
- The incoming messages after processing.
- See Also:
DistributionModule.processMessages(ClientMessages)
,
DestinationImpl.preProcess(AgentId, ClientMessages)
toString
public java.lang.String toString()
- Description copied from class:
TopicImpl
- Returns a string representation of this destination.
- Specified by:
toString
in interface DestinationImplMBean
- Overrides:
toString
in class TopicImpl
close
public void close()
Copyright © 2010 ScalAgent D.T.. All Rights Reserved.