summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRobert Greig <rgreig@apache.org>2007-01-29 11:08:42 +0000
committerRobert Greig <rgreig@apache.org>2007-01-29 11:08:42 +0000
commitef4f924560116d10b57d66c311c33829492650ec (patch)
tree2c4b0855a6cb21a6d1910e37b71090a00f104197
parente9b31c99401eef29ece619929f2ad269e6f6c2a9 (diff)
downloadqpid-python-ef4f924560116d10b57d66c311c33829492650ec.tar.gz
QPID-324 : Patch supplied by Rob Godfrey - Only send byte indicating topic / queue / other in properties field table, not whole destination
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@501008 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java11
1 files changed, 8 insertions, 3 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java
index b634f48c1e..bc9e7137dc 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java
@@ -58,6 +58,10 @@ public abstract class AMQDestination implements Destination, Referenceable
private static final int IS_EXCLUSIVE_MASK = 0x2;
private static final int IS_AUTODELETE_MASK = 0x4;
+ public static final byte QUEUE_TYPE = 1;
+ public static final byte TOPIC_TYPE = 2;
+ public static final byte UNKNOWN_TYPE = 3;
+
protected AMQDestination(String url) throws URLSyntaxException
{
this(new AMQBindingURL(url));
@@ -344,7 +348,7 @@ public abstract class AMQDestination implements Destination, Referenceable
{
return false;
}
- if (_isExclusive != that._isExclusive)
+ /* if (_isExclusive != that._isExclusive)
{
return false;
}
@@ -352,6 +356,7 @@ public abstract class AMQDestination implements Destination, Referenceable
{
return false;
}
+ */
return true;
}
@@ -365,8 +370,8 @@ public abstract class AMQDestination implements Destination, Referenceable
{
result = 29 * result + _queueName.hashCode();
}
- result = result * (_isExclusive ? 13 : 7);
- result = result * (_isAutoDelete ? 13 : 7);
+// result = result * (_isExclusive ? 13 : 7);
+// result = result * (_isAutoDelete ? 13 : 7);
return result;
}