diff options
Diffstat (limited to 'qpid/java/client/src/main/java/org/apache/qpid/jms/QpidQueue.java')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/jms/QpidQueue.java | 32 |
1 files changed, 19 insertions, 13 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/jms/QpidQueue.java b/qpid/java/client/src/main/java/org/apache/qpid/jms/QpidQueue.java index d37924566a..de5014c7bc 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/jms/QpidQueue.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/jms/QpidQueue.java @@ -23,24 +23,30 @@ package org.apache.qpid.jms; import javax.jms.JMSException; import javax.jms.Queue; +import org.apache.qpid.jms.QpidDestination.DestinationType; + public class QpidQueue extends QpidDestination implements Queue { - public QpidQueue() - { - super(DestinationType.QUEUE); - } + public QpidQueue() + { + } - public QpidQueue(String str) throws JMSException - { - super(DestinationType.QUEUE); + public QpidQueue(String str) throws JMSException + { setDestinationString(str); - } + } + + @Override + public DestinationType getType() + { + return DestinationType.QUEUE; + } - @Override - public String getQueueName() throws JMSException - { - return address.getName(); - } + @Override + public String getQueueName() throws JMSException + { + return _address.getName(); + } @Override public boolean equals(Object obj) |