summaryrefslogtreecommitdiff
path: root/java/client/src
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2007-05-24 09:57:00 +0000
committerRobert Godfrey <rgodfrey@apache.org>2007-05-24 09:57:00 +0000
commit2c5428300dbf8e0025b8e8cb010ff5e818c1a77e (patch)
tree16d48352f7aac669beaa10ec3d750038e15cad6f /java/client/src
parent13a373d975a60d45b2dd6de4c3cc821296330e16 (diff)
downloadqpid-python-2c5428300dbf8e0025b8e8cb010ff5e818c1a77e.tar.gz
QPID-482 : Small performance tweaks
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@541247 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src')
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/AMQDestination.java8
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java20
2 files changed, 13 insertions, 15 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java b/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java
index 585991d905..cc5af07b20 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java
@@ -60,9 +60,9 @@ 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;
+ public static final Integer QUEUE_TYPE = Integer.valueOf(1);
+ public static final Integer TOPIC_TYPE = Integer.valueOf(2);
+ public static final Integer UNKNOWN_TYPE = Integer.valueOf(3);
protected AMQDestination(String url) throws URLSyntaxException
{
@@ -213,7 +213,7 @@ public abstract class AMQDestination implements Destination, Referenceable
}
public String toURL()
- {
+ {
String url = _url;
if(url == null)
{
diff --git a/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java b/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
index 13f544516a..e60539c064 100644
--- a/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
+++ b/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
@@ -79,24 +79,22 @@ public abstract class AbstractJMSMessage extends AMQMessage implements org.apach
this(contentHeader, deliveryTag);
Integer type = contentHeader.getHeaders().getInteger(CustomJMSXProperty.JMS_QPID_DESTTYPE.getShortStringName());
- int contentType = (type == null) ? AMQDestination.UNKNOWN_TYPE : type.intValue();
+
AMQDestination dest;
- switch (contentType)
- {
- case AMQDestination.QUEUE_TYPE:
+ if(AMQDestination.QUEUE_TYPE.equals(type))
+ {
dest = new AMQQueue(exchange, routingKey, routingKey);
- break;
-
- case AMQDestination.TOPIC_TYPE:
+ }
+ else if(AMQDestination.TOPIC_TYPE.equals(type))
+ {
dest = new AMQTopic(exchange, routingKey, null);
- break;
-
- default:
+ }
+ else
+ {
dest = new AMQUndefinedDestination(exchange, routingKey, null);
- break;
}
//Destination dest = AMQDestination.createDestination(url);
setJMSDestination(dest);