1 files changed, 16 insertions, 0 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/state/listener/SpecificMethodFrameListener.java b/java/client/src/main/java/org/apache/qpid/client/state/listener/SpecificMethodFrameListener.java
index 623591e0b6..4a4f4a0a38 100644
--- a/java/client/src/main/java/org/apache/qpid/client/state/listener/SpecificMethodFrameListener.java
+++ b/java/client/src/main/java/org/apache/qpid/client/state/listener/SpecificMethodFrameListener.java
@@ -36,6 +36,22 @@ public class SpecificMethodFrameListener extends BlockingMethodFrameListener
 
     public boolean processMethod(int channelId, AMQMethodBody frame) //throws AMQException
     {
+
+        //equiv to: (frame instanceof _expectedClass)
         return _expectedClass.isInstance(frame);
     }
+
+    public boolean equals(Object o)
+    {
+        if (o instanceof SpecificMethodFrameListener)
+        {
+            SpecificMethodFrameListener other = (SpecificMethodFrameListener) o;
+
+            // here we need to check if the two classes are the same.
+            return (_channelId == other._channelId) && (_expectedClass.equals(other._expectedClass));
+        }
+
+        return false;
+    }
+
 }