diff options
author | Keith Wall <kwall@apache.org> | 2012-02-07 11:30:43 +0000 |
---|---|---|
committer | Keith Wall <kwall@apache.org> | 2012-02-07 11:30:43 +0000 |
commit | 666303157da36f5c4226db8db15ed5035533192c (patch) | |
tree | 839ddb8089f22eddc36b74270979fc59e6f51b8e | |
parent | 1ab9e158a261d8762e1e418e57f241ec0a9f85a4 (diff) | |
download | qpid-python-666303157da36f5c4226db8db15ed5035533192c.tar.gz |
NO-JIRA: Remove unnecessary getters added by recent commit 1236867
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1241429 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 87 |
1 files changed, 0 insertions, 87 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java index 3037c7f420..94df8b2ac4 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java @@ -277,49 +277,7 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic /** Flow control */ private FlowControlIndicator _flowControl = new FlowControlIndicator(); - /** - * Used to reference durable subscribers so that requests for unsubscribe can be handled correctly. Note this only - * keeps a record of subscriptions which have been created in the current instance. It does not remember - * subscriptions between executions of the client. - */ - protected ConcurrentHashMap<String, TopicSubscriberAdaptor<C>> getSubscriptions() - { - return _subscriptions; - } - /** - * Holds a mapping from message consumers to their identifying names, so that their subscriptions may be looked - * up in the {@link #_subscriptions} map. - */ - protected ConcurrentHashMap<C, String> getReverseSubscriptionMap() - { - return _reverseSubscriptionMap; - } - - /** - * Locks to keep access to subscriber details atomic. - * <p> - * Added for QPID2418 - */ - protected Lock getSubscriberDetails() - { - return _subscriberDetails; - } - - protected Lock getSubscriberAccess() - { - return _subscriberAccess; - } - - /** - * Used to hold incoming messages. - * - * @todo Weaken the type once {@link org.apache.qpid.client.util.FlowControllingBlockingQueue} implements Queue. - */ - protected FlowControllingBlockingQueue getQueue() - { - return _queue; - } /** Holds the highest received delivery tag. */ protected AtomicLong getHighestDeliveryTag() @@ -333,33 +291,18 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic return _prefetchedMessageTags; } - protected void setPrefetchedMessageTags(ConcurrentLinkedQueue<Long> prefetchedMessageTags) - { - _prefetchedMessageTags = prefetchedMessageTags; - } - /** All the not yet acknowledged message tags */ protected ConcurrentLinkedQueue<Long> getUnacknowledgedMessageTags() { return _unacknowledgedMessageTags; } - protected void setUnacknowledgedMessageTags(ConcurrentLinkedQueue<Long> unacknowledgedMessageTags) - { - _unacknowledgedMessageTags = unacknowledgedMessageTags; - } - /** All the delivered message tags */ protected ConcurrentLinkedQueue<Long> getDeliveredMessageTags() { return _deliveredMessageTags; } - protected void setDeliveredMessageTags(ConcurrentLinkedQueue<Long> deliveredMessageTags) - { - _deliveredMessageTags = deliveredMessageTags; - } - /** Holds the dispatcher thread for this session. */ protected Dispatcher getDispatcher() { @@ -387,11 +330,6 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic return _messageFactoryRegistry; } - protected void setMessageFactoryRegistry(MessageFactoryRegistry messageFactoryRegistry) - { - _messageFactoryRegistry = messageFactoryRegistry; - } - /** * Maps from identifying tags to message consumers, in order to pass dispatch incoming messages to the right * consumer. @@ -401,42 +339,17 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic return _consumers; } - /** - * Set when the dispatcher should direct incoming messages straight into the UnackedMessage list instead of - * to the syncRecieveQueue or MessageListener. Used during cleanup, e.g. in Session.recover(). - */ - protected boolean isUsingDispatcherForCleanup() - { - return _usingDispatcherForCleanup; - } - protected void setUsingDispatcherForCleanup(boolean usingDispatcherForCleanup) { _usingDispatcherForCleanup = usingDispatcherForCleanup; } - /** - * Used to ensure that only the first call to start the dispatcher can unsuspend the channel. - * - * @todo This is accessed only within a synchronized method, so does not need to be atomic. - */ - protected AtomicBoolean getFirstDispatcher() - { - return _firstDispatcher; - } - /** Used to indicate that the session should start pre-fetching messages as soon as it is started. */ protected boolean isImmediatePrefetch() { return _immediatePrefetch; } - /** Indicates that runtime exceptions should be generated on vilations of the strict AMQP. */ - protected boolean isStrictAMQPFATAL() - { - return _strictAMQPFATAL; - } - public static final class IdToConsumerMap<C extends BasicMessageConsumer> { private final BasicMessageConsumer[] _fastAccessConsumers = new BasicMessageConsumer[16]; |