You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2014/10/09 00:58:27 UTC
[4/5] git commit: Fix isEmpty()

Fix isEmpty()

Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/37805022
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/37805022
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/37805022

Branch: refs/heads/master
Commit: 3780502243d99c826685ff6033eecfb2ae9a3769
Parents: fe1114d
Author: Timothy Bish <ta...@gmail.com>
Authored: Wed Oct 8 18:46:09 2014 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Wed Oct 8 18:46:09 2014 -0400

----------------------------------------------------------------------
 .../provider/amqp/message/AmqpJmsTextMessageFacade.java   | 10 ++++++++++
 1 file changed, 10 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/37805022/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsTextMessageFacade.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsTextMessageFacade.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsTextMessageFacade.java
index a7a55cd..e1da812 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsTextMessageFacade.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsTextMessageFacade.java
@@ -145,6 +145,16 @@ public class AmqpJmsTextMessageFacade extends AmqpJmsMessageFacade implements Jm
 
         if (body == null) {
             return true;
+        } else if (body instanceof AmqpValue) {
+            AmqpValue value = (AmqpValue) body;
+            if (value.getValue() == null) {
+                return true;
+            } else {
+                String text = (String) value.getValue();
+                if (text.isEmpty()) {
+                    return true;
+                }
+            }
         } else if (body instanceof Data) {
             Data data = (Data) body;
             if (data.getValue() == null || data.getValue().getLength() == 0) {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org