org.objectweb.joram.mom.dest
Class DistributionTopicImpl

java.lang.Object
  extended by org.objectweb.joram.mom.dest.DestinationImpl
      extended by org.objectweb.joram.mom.dest.TopicImpl
          extended by 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

Field Summary
private  DistributionModule distributionModule
           
static org.objectweb.util.monolog.api.Logger logger
           
private  java.util.Properties properties
           
private static long serialVersionUID
          define serialVersionUID for interoperability
 
Fields inherited from class org.objectweb.joram.mom.dest.TopicImpl
alreadySentLocally, fatherId, friends, selectors, subscribers
 
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
DistributionTopicImpl(AgentId adminId, java.util.Properties properties)
          Constructs a DistributionTopicImpl instance.
 
Method Summary
 void close()
           
 void initialize(boolean firstTime)
          Initializes the destination.
 ClientMessages preProcess(AgentId from, ClientMessages cm)
          This method is needed to add processing before the standard handling.
 java.lang.String toString()
          Returns a string representation of this destination.
 
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
 

Field Detail

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
Constructor Detail

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
Method Detail

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 message
cm - 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.