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 | 24 |
1 files changed, 24 insertions, 0 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 a1183240d6..d37924566a 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 @@ -41,4 +41,28 @@ public class QpidQueue extends QpidDestination implements Queue { return address.getName(); } + + @Override + public boolean equals(Object obj) + { + if (this == obj) + { + return true; + } + + if (!(obj instanceof QpidQueue)) + { + return false; + } + + QpidQueue queue = (QpidQueue)obj; + try + { + return getQueueName().equals(queue.getQueueName()); + } + catch (Exception e) + { + return false; + } + } } |