diff options
Diffstat (limited to 'qpid/java/client/src')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java index 9657a49d98..60d48f02ef 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java @@ -1187,7 +1187,10 @@ public class AMQSession_0_10 extends AMQSession<BasicMessageConsumer_0_10, Basic for (String key: source.keySet()) { match = target.containsKey(key) && - target.get(key).equals(source.get(key)); + (target.get(key).equals(source.get(key)) + || (target.get(key) instanceof Number) + && source.get(key) instanceof Number && + (((Number) target.get(key)).longValue()) == (((Number) source.get(key)).longValue())); if (!match) { |