svn commit: r488279 - /incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java

[bhupendrab]

Author: bhupendrab
Date: Mon Dec 18 06:28:18 2006
New Revision: 488279

URL: http://svn.apache.org/viewvc?view=rev&rev=488279
Log:
null check added for null header properties

Modified:
    
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java

Modified: 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java?view=diff&rev=488279&r1=488278&r2=488279
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java
 Mon Dec 18 06:28:18 2006
@@ -275,22 +275,29 @@
         // get message content
         List<ContentBody> cBodies = msg.getContentBodies();
         List<Byte> msgContent = new ArrayList<Byte>();
-        for (ContentBody body : cBodies)
+        if (cBodies != null)
         {
-            if (body.getSize() != 0)
+            for (ContentBody body : cBodies)
             {
-                ByteBuffer slice = body.payload.slice();
-                for (int j = 0; j < slice.limit(); j++)
+                if (body.getSize() != 0)
                 {
-                    msgContent.add(slice.get());
+                    ByteBuffer slice = body.payload.slice();
+                    for (int j = 0; j < slice.limit(); j++)
+                    {
+                        msgContent.add(slice.get());
+                    }
                 }
             }
         }
 
         // Create header attributes list
         BasicContentHeaderProperties headerProperties = 
(BasicContentHeaderProperties) msg.getContentHeaderBody().properties;
-        String mimeType = headerProperties.getContentType();
-        String encoding = headerProperties.getEncoding() == null ? "" : 
headerProperties.getEncoding();
+        String mimeType = null, encoding = null;
+        if (headerProperties != null)
+        {
+            mimeType = headerProperties.getContentType();
+            encoding = headerProperties.getEncoding() == null ? "" : 
headerProperties.getEncoding();
+        }
         Object[] itemValues = {msgId, mimeType, encoding, 
msgContent.toArray(new Byte[0])};
 
         return new CompositeDataSupport(_msgContentType, 
_msgContentAttributes, itemValues);