Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » [javadoc | source]
abstract public class: AbstractSubscription [javadoc | source]

All Implemented Interfaces:

Direct Known Subclasses:
    QueueBrowserSubscription, DurableTopicSubscription, PrefetchSubscription, TopicSubscription, QueueSubscription

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 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  Broker broker     
protected  ConnectionContext context     
protected  ConsumerInfo info     
protected final  DestinationFilter destinationFilter     
protected final  CopyOnWriteArrayList<Destination> destinations     
 public AbstractSubscription(Broker broker,
    ConnectionContext context,
    ConsumerInfo info) throws InvalidSelectorException 
Method from Summary:
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 Detail:
 public  void add(ConnectionContext context,
    Destination destination) throws Exception 
 public  void addDestination(Destination destination) 
    Add a destination
 public boolean addRecoveredMessage(ConnectionContext context,
    MessageReference message) throws Exception 
 public int countBeforeFull() 
 protected  void doAddRecoveredMessage(MessageReference message) throws Exception 
 public  void gc() 
 public ActiveMQDestination getActiveMQDestination() 
 public ConsumerInfo getConsumerInfo() 
 public ConnectionContext getContext() 
 public int getCursorMemoryHighWaterMark() 
 public int getInFlightUsage() 
 public ConsumerInfo getInfo() 
 public ObjectName getObjectName() 
 public int getPrefetchSize() 
 public String getSelector() 
 public BooleanExpression getSelectorExpression() 
 public boolean isBrowser() 
 public boolean isRecoveryRequired() 
 public boolean isSlave() 
 public boolean matches(ActiveMQDestination destination) 
 public boolean matches(MessageReference node,
    MessageEvaluationContext context) throws IOException 
 public List<MessageReference> remove(ConnectionContext context,
    Destination destination) throws Exception 
 public  void removeDestination(Destination destination) 
    Remove a destination
 public  void setCursorMemoryHighWaterMark(int cursorMemoryHighWaterMark) 
 public  void setObjectName(ObjectName objectName) 
 public  void setPrefetchSize(int newSize) 
 public  void setSelector(String selector) throws InvalidSelectorException