summaryrefslogtreecommitdiff
path: root/qpid/java
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2014-04-24 21:09:47 +0000
committerRobert Godfrey <rgodfrey@apache.org>2014-04-24 21:09:47 +0000
commit690303476c2ab39cf24eaff180f1e385c8528fc0 (patch)
tree7e62a7c2357cd630907b63efe22671607dc51357 /qpid/java
parent0fa129757fc880195d638401be3eff31df5421ae (diff)
downloadqpid-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.java62
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()