diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2014-04-24 21:09:47 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2014-04-24 21:09:47 +0000 |
| commit | 690303476c2ab39cf24eaff180f1e385c8528fc0 (patch) | |
| tree | 7e62a7c2357cd630907b63efe22671607dc51357 /qpid/java | |
| parent | 0fa129757fc880195d638401be3eff31df5421ae (diff) | |
| download | qpid-python-690303476c2ab39cf24eaff180f1e385c8528fc0.tar.gz | |
QPID-5580 : Address review comments from Keith Wall / remove dead code
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1589882 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java | 62 |
1 files changed, 0 insertions, 62 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java index 0e04329a95..e96850ca85 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java @@ -96,7 +96,6 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>> private static final Logger _logger = Logger.getLogger(AbstractQueue.class); public static final String SHARED_MSG_GROUP_ARG_VALUE = "1"; - private static final String QPID_NO_GROUP = "qpid.no-group"; private static final QueueNotificationListener NULL_NOTIFICATION_LISTENER = new QueueNotificationListener() { @@ -203,9 +202,6 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>> private final CopyOnWriteArrayList<BindingImpl> _bindings = new CopyOnWriteArrayList<BindingImpl>(); private Map<String, Object> _arguments; - //TODO : persist creation time - private long _createTime = System.currentTimeMillis(); - /** the maximum delivery count for each message on this queue or 0 if maximum delivery count is not to be enforced. */ @ManagedAttributeField private int _maximumDeliveryAttempts; @@ -250,57 +246,6 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>> } } - public void validate() - { - super.validate(); - if (_virtualHost == null) - { - throw new IllegalArgumentException("Virtual Host must not be null"); - } - - if (getName() == null) - { - throw new IllegalArgumentException("Queue name must not be null"); - } - - addChangeListener(new ConfigurationChangeListener() - { - @Override - public void stateChanged(final ConfiguredObject object, final State oldState, final State newState) - { - - } - - @Override - public void childAdded(final ConfiguredObject object, final ConfiguredObject child) - { - - } - - @Override - public void childRemoved(final ConfiguredObject object, final ConfiguredObject child) - { - - } - - @Override - public void attributeSet(final ConfiguredObject object, - final String attributeName, - final Object oldAttributeValue, - final Object newAttributeValue) - { - onAttributeChange(attributeName, oldAttributeValue, newAttributeValue); - } - }); - } - - private void onAttributeChange(final String attributeName, - final Object oldAttributeValue, - final Object newAttributeValue) - { - - } - protected void onOpen() { super.onOpen(); @@ -421,8 +366,6 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>> throw new IllegalConfigurationException("Flow resume size can't be greater than flow control size"); } - final String ownerString = getOwner(); - // Log the creation of this Queue. // The priorities display is toggled on if we set priorities > 0 getEventLogger().message(_logSubject, @@ -1453,11 +1396,6 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>> } - public long getCreateTime() - { - return _createTime; - } - // ------ Management functions public long clearQueue() |
