summaryrefslogtreecommitdiff
path: root/java/client/src/main
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2007-01-24 21:19:48 +0000
committerKim van der Riet <kpvdr@apache.org>2007-01-24 21:19:48 +0000
commitcc7f9b9cae4b4d2abea744dd432436c36d7fc9e0 (patch)
tree4838d976b506875c070edeeb0e9a37b844e3b621 /java/client/src/main
parentda2b073621927734685d5753b57864e1af45c53f (diff)
downloadqpid-python-cc7f9b9cae4b4d2abea744dd432436c36d7fc9e0.tar.gz
Fix for TextMessageTest failure
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499571 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src/main')
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java68
1 files changed, 61 insertions, 7 deletions
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 10b893188c..2de86b2cb3 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
@@ -263,44 +263,98 @@ public abstract class AbstractJMSMessage extends AMQMessage implements org.apach
public boolean getBooleanProperty(String propertyName) throws JMSException
{
checkPropertyName(propertyName);
-
- return getMessageHeaders().getJMSHeaders().getBoolean(propertyName);
+ Boolean b = getMessageHeaders().getJMSHeaders().getBoolean(propertyName);
+ if (b != null)
+ return b;
+ return false;
+// return getMessageHeaders().getJMSHeaders().getBoolean(propertyName);
}
public byte getByteProperty(String propertyName) throws JMSException
{
checkPropertyName(propertyName);
- return getMessageHeaders().getJMSHeaders().getByte(propertyName);
+ Byte b = getMessageHeaders().getJMSHeaders().getByte(propertyName);
+ if (b == null)
+ throw new NumberFormatException("Byte value null");
+ return b;
+// return getMessageHeaders().getJMSHeaders().getByte(propertyName);
}
public short getShortProperty(String propertyName) throws JMSException
{
checkPropertyName(propertyName);
- return getMessageHeaders().getJMSHeaders().getShort(propertyName);
+ Short s = getMessageHeaders().getJMSHeaders().getShort(propertyName);
+ if (s != null)
+ return s;
+ // try Byte
+ Byte b = getMessageHeaders().getJMSHeaders().getByte(propertyName);
+ if (b == null)
+ throw new NumberFormatException("Short value null");
+ return (short)b;
+// return getMessageHeaders().getJMSHeaders().getShort(propertyName);
}
public int getIntProperty(String propertyName) throws JMSException
{
checkPropertyName(propertyName);
- return getMessageHeaders().getJMSHeaders().getInteger(propertyName);
+ Integer i = getMessageHeaders().getJMSHeaders().getInteger(propertyName);
+ if (i != null)
+ return i;
+ // try Short
+ Short s = getMessageHeaders().getJMSHeaders().getShort(propertyName);
+ if (s != null)
+ return s;
+ // try Byte
+ Byte b = getMessageHeaders().getJMSHeaders().getByte(propertyName);
+ if (b == null)
+ throw new NumberFormatException("Int value null");
+ return (short)b;
+// return getMessageHeaders().getJMSHeaders().getInteger(propertyName);
}
public long getLongProperty(String propertyName) throws JMSException
{
checkPropertyName(propertyName);
- return getMessageHeaders().getJMSHeaders().getLong(propertyName);
+ Long l = getMessageHeaders().getJMSHeaders().getLong(propertyName);
+ if (l != null)
+ return l;
+ Integer i = getMessageHeaders().getJMSHeaders().getInteger(propertyName);
+ if (i != null)
+ return i;
+ // try Short
+ Short s = getMessageHeaders().getJMSHeaders().getShort(propertyName);
+ if (s != null)
+ return s;
+ // try Byte
+ Byte b = getMessageHeaders().getJMSHeaders().getByte(propertyName);
+ if (b == null)
+ throw new NumberFormatException("Long value null");
+ return (short)b;
+// return getMessageHeaders().getJMSHeaders().getLong(propertyName);
}
public float getFloatProperty(String propertyName) throws JMSException
{
checkPropertyName(propertyName);
+// Float f = getMessageHeaders().getJMSHeaders().getFloat(propertyName);
+// if (f == null)
+// throw new NumberFormatException("Float value null");
+// return f;
return getMessageHeaders().getJMSHeaders().getFloat(propertyName);
}
public double getDoubleProperty(String propertyName) throws JMSException
{
checkPropertyName(propertyName);
- return getMessageHeaders().getJMSHeaders().getDouble(propertyName);
+ Double d = getMessageHeaders().getJMSHeaders().getDouble(propertyName);
+ if (d != null)
+ return d;
+ // try Float
+ Float f = getMessageHeaders().getJMSHeaders().getFloat(propertyName);
+// if (f == null)
+// throw new NumberFormatException("Double value null");
+ return (double)f;
+// return getMessageHeaders().getJMSHeaders().getDouble(propertyName);
}
public String getStringProperty(String propertyName) throws JMSException