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: DurableTopicSubscription [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.region.AbstractSubscription
      org.apache.activemq.broker.region.PrefetchSubscription
         org.apache.activemq.broker.region.DurableTopicSubscription

All Implemented Interfaces:
    UsageListener, Subscription

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Fields inherited from org.apache.activemq.broker.region.PrefetchSubscription:
scheduler,  pending,  dispatched,  prefetchExtension,  enqueueCounter,  dispatchCounter,  dequeueCounter,  usageManager,  audit
Fields inherited from org.apache.activemq.broker.region.AbstractSubscription:
broker,  context,  info,  destinationFilter,  destinations
Constructor:
 public DurableTopicSubscription(Broker broker,
    SystemUsage usageManager,
    ConnectionContext context,
    ConsumerInfo info,
    boolean keepDurableSubsActive) throws JMSException 
Method from org.apache.activemq.broker.region.DurableTopicSubscription Summary:
acknowledge,   activate,   add,   add,   canDispatch,   createMessageDispatch,   deactivate,   destroy,   doAddRecoveredMessage,   gc,   getPendingQueueSize,   getSubscriptionKey,   isActive,   isDropped,   isFull,   onUsageChanged,   setSelector,   toString
Methods from org.apache.activemq.broker.region.PrefetchSubscription:
acknowledge,   acknowledge,   add,   add,   assertAckMatchesDispatched,   canDispatch,   countBeforeFull,   createMessageDispatch,   dispatch,   dispatchPending,   getDequeueCounter,   getDispatchedCounter,   getDispatchedQueueSize,   getEnqueueCounter,   getInFlightSize,   getMaxAuditDepth,   getMaxProducersToAudit,   getPending,   getPendingQueueSize,   isDropped,   isFull,   isHighWaterMark,   isLowWaterMark,   isRecoveryRequired,   onDispatch,   processMessageDispatchNotification,   pullMessage,   pullTimeout,   remove,   sendToDLQ,   setMaxAuditDepth,   setMaxProducersToAudit,   setPending,   updateConsumerPrefetch
Methods from org.apache.activemq.broker.region.AbstractSubscription:
add,   addDestination,   addRecoveredMessage,   countBeforeFull,   doAddRecoveredMessage,   gc,   getActiveMQDestination,   getConsumerInfo,   getContext,   getCursorMemoryHighWaterMark,   getInFlightUsage,   getInfo,   getObjectName,   getPrefetchSize,   getSelector,   getSelectorExpression,   isBrowser,   isRecoveryRequired,   isSlave,   matches,   matches,   remove,   removeDestination,   setCursorMemoryHighWaterMark,   setObjectName,   setPrefetchSize,   setSelector
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.region.DurableTopicSubscription Detail:
 protected  void acknowledge(ConnectionContext context,
    MessageAck ack,
    MessageReference node) throws IOException 
 public  void activate(SystemUsage memoryManager,
    ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public  void add(MessageReference node) throws Exception 
 public  void add(ConnectionContext context,
    Destination destination) throws Exception 
 protected boolean canDispatch(MessageReference node) 
 protected MessageDispatch createMessageDispatch(MessageReference node,
    Message message) 
 public  void deactivate(boolean keepDurableSubsActive) throws Exception 
 public  void destroy() 
    Release any references that we are holding.
 protected  void doAddRecoveredMessage(MessageReference message) throws Exception 
 public  void gc() 
 public int getPendingQueueSize() 
 public SubscriptionKey getSubscriptionKey() 
 public boolean isActive() 
 protected boolean isDropped(MessageReference node) 
 public boolean isFull() 
 public  void onUsageChanged(Usage usage,
    int oldPercentUsage,
    int newPercentUsage) 
 public  void setSelector(String selector) throws InvalidSelectorException 
 public synchronized String toString()