diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2012-04-16 10:44:03 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2012-04-16 10:44:03 +0000 |
| commit | 673511e747260d62abfe3220225f7443b182040b (patch) | |
| tree | 7b9e41d9644b96d5904b1e3a430279ff1a425bcb /qpid/java | |
| parent | 8c7131dbb10c794f01797cecb1336deaab334cf4 (diff) | |
| download | qpid-python-673511e747260d62abfe3220225f7443b182040b.tar.gz | |
QPID-3949 : [Java AMQP 1.0] Fix descriptors on filters
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1326555 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
8 files changed, 14 insertions, 10 deletions
diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/ExactSubjectFilterConstructor.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/ExactSubjectFilterConstructor.java index 48bec31797..90eff967b2 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/ExactSubjectFilterConstructor.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/ExactSubjectFilterConstructor.java @@ -32,7 +32,7 @@ public class ExactSubjectFilterConstructor extends DescribedTypeConstructor<Exac { private static final Object[] DESCRIPTORS = { - Symbol.valueOf("amqp:exact-subject-filter:string"), + Symbol.valueOf("apache.org:legacy-amqp-direct-binding:string"), 0x0000468C00000000L }; private static final ExactSubjectFilterConstructor INSTANCE = new ExactSubjectFilterConstructor(); diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/ExactSubjectFilterWriter.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/ExactSubjectFilterWriter.java index 75e2df4b65..2e95aba7a2 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/ExactSubjectFilterWriter.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/ExactSubjectFilterWriter.java @@ -25,7 +25,6 @@ package org.apache.qpid.amqp_1_0.type.messaging.codec; import org.apache.qpid.amqp_1_0.codec.AbstractDescribedTypeWriter; import org.apache.qpid.amqp_1_0.codec.ValueWriter; -import org.apache.qpid.amqp_1_0.type.Symbol; import org.apache.qpid.amqp_1_0.type.messaging.ExactSubjectFilter; public class ExactSubjectFilterWriter extends AbstractDescribedTypeWriter<ExactSubjectFilter> @@ -53,7 +52,7 @@ public class ExactSubjectFilterWriter extends AbstractDescribedTypeWriter<ExactS protected Object getDescriptor() { - return Symbol.valueOf("amqp:exact-subject-filter:string"); + return 0x0000468C00000000L; } @Override diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/JMSSelectorFilterConstructor.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/JMSSelectorFilterConstructor.java index 1e2488c3ea..ac377f8461 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/JMSSelectorFilterConstructor.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/JMSSelectorFilterConstructor.java @@ -26,6 +26,7 @@ package org.apache.qpid.amqp_1_0.type.messaging.codec; import org.apache.qpid.amqp_1_0.codec.DescribedTypeConstructor; import org.apache.qpid.amqp_1_0.codec.DescribedTypeConstructorRegistry; import org.apache.qpid.amqp_1_0.type.Symbol; +import org.apache.qpid.amqp_1_0.type.UnsignedLong; import org.apache.qpid.amqp_1_0.type.messaging.JMSSelectorFilter; public class JMSSelectorFilterConstructor extends DescribedTypeConstructor<JMSSelectorFilter> @@ -33,7 +34,7 @@ public class JMSSelectorFilterConstructor extends DescribedTypeConstructor<JMSSe private static final Object[] DESCRIPTORS = { Symbol.valueOf("apache.org:jms-selector-filter:string"), - Long.valueOf(0x0000468C00000004L) + UnsignedLong.valueOf(0x0000468C00000004L) }; private static final JMSSelectorFilterConstructor INSTANCE = new JMSSelectorFilterConstructor(); diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/JMSSelectorFilterWriter.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/JMSSelectorFilterWriter.java index a603a10d6d..f363f0f1a4 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/JMSSelectorFilterWriter.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/JMSSelectorFilterWriter.java @@ -25,6 +25,7 @@ package org.apache.qpid.amqp_1_0.type.messaging.codec; import org.apache.qpid.amqp_1_0.codec.AbstractDescribedTypeWriter; import org.apache.qpid.amqp_1_0.codec.ValueWriter; +import org.apache.qpid.amqp_1_0.type.UnsignedLong; import org.apache.qpid.amqp_1_0.type.messaging.JMSSelectorFilter; public class JMSSelectorFilterWriter extends AbstractDescribedTypeWriter<JMSSelectorFilter> @@ -52,7 +53,7 @@ public class JMSSelectorFilterWriter extends AbstractDescribedTypeWriter<JMSSele protected Object getDescriptor() { - return 0x0000468C00000004L; + return UnsignedLong.valueOf(0x0000468C00000004L); } @Override diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/MatchingSubjectFilterConstructor.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/MatchingSubjectFilterConstructor.java index d9cdc7bbb9..13e365fb5a 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/MatchingSubjectFilterConstructor.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/MatchingSubjectFilterConstructor.java @@ -26,13 +26,14 @@ package org.apache.qpid.amqp_1_0.type.messaging.codec; import org.apache.qpid.amqp_1_0.codec.DescribedTypeConstructor; import org.apache.qpid.amqp_1_0.codec.DescribedTypeConstructorRegistry; import org.apache.qpid.amqp_1_0.type.Symbol; +import org.apache.qpid.amqp_1_0.type.UnsignedLong; import org.apache.qpid.amqp_1_0.type.messaging.MatchingSubjectFilter; public class MatchingSubjectFilterConstructor extends DescribedTypeConstructor<MatchingSubjectFilter> { private static final Object[] DESCRIPTORS = { - Symbol.valueOf("amqp:matching-subject-filter:string"), + Symbol.valueOf("apache.org:legacy-amqp-topic-binding:string"), UnsignedLong.valueOf(0x0000468C00000001L) }; private static final MatchingSubjectFilterConstructor INSTANCE = new MatchingSubjectFilterConstructor(); diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/MatchingSubjectFilterWriter.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/MatchingSubjectFilterWriter.java index 29fd304831..3c260e66d4 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/MatchingSubjectFilterWriter.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/MatchingSubjectFilterWriter.java @@ -25,7 +25,7 @@ package org.apache.qpid.amqp_1_0.type.messaging.codec; import org.apache.qpid.amqp_1_0.codec.AbstractDescribedTypeWriter; import org.apache.qpid.amqp_1_0.codec.ValueWriter; -import org.apache.qpid.amqp_1_0.type.Symbol; +import org.apache.qpid.amqp_1_0.type.UnsignedLong; import org.apache.qpid.amqp_1_0.type.messaging.MatchingSubjectFilter; public class MatchingSubjectFilterWriter extends AbstractDescribedTypeWriter<MatchingSubjectFilter> @@ -53,7 +53,7 @@ public class MatchingSubjectFilterWriter extends AbstractDescribedTypeWriter<Mat protected Object getDescriptor() { - return Symbol.valueOf("amqp:matching-subject-filter:string"); + return UnsignedLong.valueOf(0x0000468C00000001L); } @Override diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/NoLocalFilterConstructor.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/NoLocalFilterConstructor.java index dcd1a3fea8..b1c5e1dcfe 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/NoLocalFilterConstructor.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/NoLocalFilterConstructor.java @@ -26,13 +26,14 @@ package org.apache.qpid.amqp_1_0.type.messaging.codec; import org.apache.qpid.amqp_1_0.codec.DescribedTypeConstructor; import org.apache.qpid.amqp_1_0.codec.DescribedTypeConstructorRegistry; import org.apache.qpid.amqp_1_0.type.Symbol; +import org.apache.qpid.amqp_1_0.type.UnsignedLong; import org.apache.qpid.amqp_1_0.type.messaging.NoLocalFilter; public class NoLocalFilterConstructor extends DescribedTypeConstructor<NoLocalFilter> { private static final Object[] DESCRIPTORS = { - Symbol.valueOf("apache.org:jms-no-local-filter:list"), 0x0000468C00000003L + Symbol.valueOf("apache.org:jms-no-local-filter:list"), UnsignedLong.valueOf(0x0000468C00000003L) }; private static final NoLocalFilterConstructor INSTANCE = new NoLocalFilterConstructor(); diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/NoLocalFilterWriter.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/NoLocalFilterWriter.java index cbb83a8e87..8308f63101 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/NoLocalFilterWriter.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/messaging/codec/NoLocalFilterWriter.java @@ -26,6 +26,7 @@ package org.apache.qpid.amqp_1_0.type.messaging.codec; import org.apache.qpid.amqp_1_0.codec.AbstractDescribedTypeWriter; import org.apache.qpid.amqp_1_0.codec.ListWriter; import org.apache.qpid.amqp_1_0.codec.ValueWriter; +import org.apache.qpid.amqp_1_0.type.UnsignedLong; import org.apache.qpid.amqp_1_0.type.messaging.NoLocalFilter; public class NoLocalFilterWriter extends AbstractDescribedTypeWriter<NoLocalFilter> @@ -62,7 +63,7 @@ public class NoLocalFilterWriter extends AbstractDescribedTypeWriter<NoLocalFilt protected Object getDescriptor() { - return 0x0000468C00000003L; + return UnsignedLong.valueOf(0x0000468C00000003L); } @Override |
