diff options
| author | Robert Gemmell <robbie@apache.org> | 2010-09-05 18:51:15 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2010-09-05 18:51:15 +0000 |
| commit | 8b2e499dc048359c2bc37d1e9e36b2f8cd3cb3bc (patch) | |
| tree | 214edd653b834ca5efcf0e1521937b063a85acab /qpid/java/broker/src | |
| parent | ba143bd7b07e39ce07f1fb7bbf3cd107a515b469 (diff) | |
| download | qpid-python-8b2e499dc048359c2bc37d1e9e36b2f8cd3cb3bc.tar.gz | |
QPID-2418: updates to fix test failures when using the 0-10 client test profiles.
Use a transacted session when querying for queue counts following consumption, as the 0-10 client batches auto-acks asynchronously.
Always send the selector filter argument even if empty, to allow querying the brokers via 0-10 to detect whether the selector is being added/removed/modified at subscribe time.
Enable the Java broker to perform argument matching during the 0-10 isBound check.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@992856 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSessionDelegate.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSessionDelegate.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSessionDelegate.java index 44a677a76d..7b51b68e61 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSessionDelegate.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSessionDelegate.java @@ -756,7 +756,9 @@ public class ServerSessionDelegate extends SessionDelegate if(method.hasArguments()) { - // TODO + FieldTable args = FieldTable.convertToFieldTable(method.getArguments()); + + result.setArgsNotMatched(!exchange.isBound(new AMQShortString(method.getBindingKey()), args, queue)); } if(queueMatched) { |