Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » [javadoc | source]
org.apache.activemq.broker.region
public class: Topic [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.region.BaseDestination
      org.apache.activemq.broker.region.Topic

All Implemented Interfaces:
    Task, Destination

Direct Known Subclasses:
    TempTopic

The Topic is a destination that sends a copy of a message to every active Subscription registered.
Field Summary
protected static final  Log LOG     
protected final  CopyOnWriteArrayList<Subscription> consumers     
protected final  Valve dispatchValve     
Fields inherited from org.apache.activemq.broker.region.BaseDestination:
MAX_PAGE_SIZE,  MAX_BROWSE_PAGE_SIZE,  EXPIRE_MESSAGE_PERIOD,  destination,  broker,  store,  systemUsage,  memoryUsage,  warnOnProducerFlowControl,  blockedProducerWarningInterval,  destinationStatistics,  brokerService,  regionBroker,  deadLetterStrategy,  expireMessagesPeriod,  cursorMemoryHighWaterMark
Constructor:
 public Topic(BrokerService brokerService,
    ActiveMQDestination destination,
    TopicMessageStore store,
    DestinationStatistics parentStats,
    TaskRunnerFactory taskFactory) throws Exception 
Method from org.apache.activemq.broker.region.Topic Summary:
acknowledge,   activate,   addSubscription,   browse,   deactivate,   deleteSubscription,   dispatch,   doMessageSend,   gc,   getConsumers,   getDispatchPolicy,   getSubscriptionRecoveryPolicy,   initialize,   iterate,   loadMessage,   lock,   messageExpired,   recoverRetroactiveMessages,   removeSubscription,   send,   setDispatchPolicy,   setSubscriptionRecoveryPolicy,   start,   stop,   toString,   wakeup
Methods from org.apache.activemq.broker.region.BaseDestination:
addProducer,   dispose,   fastProducer,   getActiveMQDestination,   getBlockedProducerWarningInterval,   getCursorMemoryHighWaterMark,   getDeadLetterStrategy,   getDestinationSequenceId,   getDestinationStatistics,   getExpireMessagesPeriod,   getMaxAuditDepth,   getMaxBrowsePageSize,   getMaxExpirePageSize,   getMaxPageSize,   getMaxProducersToAudit,   getMemoryUsage,   getMessageStore,   getMinimumMessageSize,   getName,   initialize,   isActive,   isAdvisdoryForFastProducers,   isAdvisoryForConsumed,   isAdvisoryForDelivery,   isAdvisoryForDiscardingMessages,   isAdvisoryForSlowConsumers,   isAdvisoryWhenFull,   isEnableAudit,   isFull,   isLazyDispatch,   isProducerFlowControl,   isSendAdvisoryIfNoConsumers,   isUseCache,   messageConsumed,   messageDelivered,   messageDiscarded,   onMessageWithNoConsumers,   processDispatchNotification,   removeProducer,   setAdvisdoryForFastProducers,   setAdvisoryForConsumed,   setAdvisoryForDelivery,   setAdvisoryForDiscardingMessages,   setAdvisoryForSlowConsumers,   setAdvisoryWhenFull,   setBlockedProducerWarningInterval,   setCursorMemoryHighWaterMark,   setDeadLetterStrategy,   setEnableAudit,   setExpireMessagesPeriod,   setLazyDispatch,   setMaxAuditDepth,   setMaxBrowsePageSize,   setMaxExpirePageSize,   setMaxPageSize,   setMaxProducersToAudit,   setMinimumMessageSize,   setProducerFlowControl,   setSendAdvisoryIfNoConsumers,   setUseCache,   slowConsumer
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.region.Topic Detail:
 public  void acknowledge(ConnectionContext context,
    Subscription sub,
    MessageAck ack,
    MessageReference node) throws IOException 
 public  void activate(ConnectionContext context,
    DurableTopicSubscription subscription) throws Exception 
 public  void addSubscription(ConnectionContext context,
    Subscription sub) throws Exception 
 public Message[] browse() 
 public  void deactivate(ConnectionContext context,
    DurableTopicSubscription sub) throws Exception 
 public  void deleteSubscription(ConnectionContext context,
    SubscriptionKey key) throws IOException 
 protected  void dispatch(ConnectionContext context,
    Message message) throws Exception 
 synchronized  void doMessageSend(ProducerBrokerExchange producerExchange,
    Message message) throws IOException, Exception 
    do send the message - this needs to be synchronized to ensure messages are stored AND dispatched in the right order
 public  void gc() 
 public List<Subscription> getConsumers() 
 public DispatchPolicy getDispatchPolicy() 
 public SubscriptionRecoveryPolicy getSubscriptionRecoveryPolicy() 
 public  void initialize() throws Exception 
 public boolean iterate() 
 public Message loadMessage(MessageId messageId) throws IOException 
 public boolean lock(MessageReference node,
    LockOwner sub) 
 public  void messageExpired(ConnectionContext context,
    Subscription subs,
    MessageReference reference) 
 protected  void recoverRetroactiveMessages(ConnectionContext context,
    Subscription subscription) throws Exception 
 public  void removeSubscription(ConnectionContext context,
    Subscription sub,
    long lastDeliveredSequenceId) throws Exception 
 public  void send(ProducerBrokerExchange producerExchange,
    Message message) throws Exception 
 public  void setDispatchPolicy(DispatchPolicy dispatchPolicy) 
 public  void setSubscriptionRecoveryPolicy(SubscriptionRecoveryPolicy subscriptionRecoveryPolicy) 
 public  void start() throws Exception 
 public  void stop() throws Exception 
 public String toString() 
 public final  void wakeup()