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

All Implemented Interfaces:
    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.
Field Summary
protected  PendingMessageCursor matched     
protected final  SystemUsage usageManager     
protected  AtomicLong dispatchedCounter     
 boolean singleDestination     
 Destination destination     
Fields inherited from org.apache.activemq.broker.region.AbstractSubscription:
broker,  context,  info,  destinationFilter,  destinations
Constructor:
 public TopicSubscription(Broker broker,
    ConnectionContext context,
    ConsumerInfo info,
    SystemUsage usageManager) throws Exception 
Method from org.apache.activemq.broker.region.TopicSubscription Summary:
acknowledge,   add,   destroy,   discarded,   getDequeueCounter,   getDispatchedCounter,   getDispatchedQueueSize,   getEnqueueCounter,   getInFlightSize,   getMatched,   getMaximumPendingMessages,   getMemoryUsageHighWaterMark,   getMessageEvictionStrategy,   getPendingQueueSize,   getPrefetchSize,   getUsageManager,   init,   isFull,   isHighWaterMark,   isLowWaterMark,   matched,   processMessageDispatchNotification,   pullMessage,   removeExpiredMessages,   setMatched,   setMaximumPendingMessages,   setMemoryUsageHighWaterMark,   setMessageEvictionStrategy,   toString,   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.TopicSubscription Detail:
 public synchronized  void acknowledge(ConnectionContext context,
    MessageAck ack) throws Exception 
 public  void add(MessageReference node) throws Exception 
 public  void destroy() 
 public int discarded() 
 public long getDequeueCounter() 
 public long getDispatchedCounter() 
 public int getDispatchedQueueSize() 
 public long getEnqueueCounter() 
 public int getInFlightSize() 
 public PendingMessageCursor getMatched() 
 public int getMaximumPendingMessages() 
 public int getMemoryUsageHighWaterMark() 
 public MessageEvictionStrategy getMessageEvictionStrategy() 
 public int getPendingQueueSize() 
 public int getPrefetchSize() 
 public SystemUsage getUsageManager() 
 public  void init() throws Exception 
 public boolean isFull() 
 public boolean isHighWaterMark() 
 public boolean isLowWaterMark() 
 public int matched() 
 public  void processMessageDispatchNotification(MessageDispatchNotification mdn) 
 public Response pullMessage(ConnectionContext context,
    MessagePull pull) throws Exception 
 protected  void removeExpiredMessages() throws IOException 
    Discard any expired messages from the matched list. Called from a synchronized block.
 public  void setMatched(PendingMessageCursor matched) 
 public  void setMaximumPendingMessages(int maximumPendingMessages) 
    Sets the maximum number of pending messages that can be matched against this consumer before old messages are discarded.
 public  void setMemoryUsageHighWaterMark(int memoryUsageHighWaterMark) 
 public  void setMessageEvictionStrategy(MessageEvictionStrategy messageEvictionStrategy) 
    Sets the eviction strategy used to decide which message to evict when the slow consumer needs to discard messages
 public String toString() 
 public  void updateConsumerPrefetch(int newPrefetch) 
    inform the MessageConsumer on the client to change it's prefetch