summaryrefslogtreecommitdiff
path: root/qpid/java
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java')
-rw-r--r--qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AMQQueue.java2
-rw-r--r--qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java30
2 files changed, 2 insertions, 30 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AMQQueue.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
index e31eac77b4..f516013c2d 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
@@ -112,8 +112,6 @@ public interface AMQQueue<X extends AMQQueue<X>>
void visit(QueueEntryVisitor visitor);
- boolean isOverfull();
-
long clearQueue();
/**
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 69c430e74c..0e04329a95 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
@@ -546,31 +546,10 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>>
@Override
public Object getAttribute(String name)
{
- if(ALTERNATE_EXCHANGE.equals(name))
- {
- return getAlternateExchange();
- }
- else if(OWNER.equals(name))
- {
- return getOwner();
- }
- else if(MESSAGE_GROUP_SHARED_GROUPS.equals(name))
- {
- //We only return the boolean value if message groups are actually in use
- return _arguments.get(MESSAGE_GROUP_KEY) == null ? null : _arguments.get(MESSAGE_GROUP_SHARED_GROUPS);
- }
- else if(QUEUE_FLOW_STOPPED.equals(name))
- {
- return isOverfull();
- }
- else if(STATE.equals(name))
+ if(STATE.equals(name))
{
return State.ACTIVE; // TODO
}
- else if (DESCRIPTION.equals(name))
- {
- return getDescription();
- }
return super.getAttribute(name);
}
@@ -2151,11 +2130,6 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>>
return _queueFlowResumeSizeBytes;
}
- public boolean isOverfull()
- {
- return _overfull.get();
- }
-
public Set<NotificationCheck> getNotificationChecks()
{
return _notificationChecks;
@@ -2648,7 +2622,7 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>>
@Override
public boolean isQueueFlowStopped()
{
- return false;
+ return _overfull.get();
}
@Override