From 690303476c2ab39cf24eaff180f1e385c8528fc0 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Thu, 24 Apr 2014 21:09:47 +0000 Subject: 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 --- .../apache/qpid/server/queue/AbstractQueue.java | 62 ---------------------- 1 file changed, 62 deletions(-) (limited to 'qpid/java') 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> 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> private final CopyOnWriteArrayList _bindings = new CopyOnWriteArrayList(); private Map _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> } } - 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> 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> } - public long getCreateTime() - { - return _createTime; - } - // ------ Management functions public long clearQueue() -- cgit v1.2.1