[hornetq-commits] JBoss hornetq SVN: r10276 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-03-01 16:44:15 -0500 (Tue, 01 Mar 2011)
New Revision: 10276

Modified:
   branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
Log:
improving data

Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java	2011-03-01 16:54:34 UTC (rev 10275)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java	2011-03-01 21:44:15 UTC (rev 10276)
@@ -2785,7 +2785,7 @@
 
    private static String describeRecord(RecordInfo info)
    {
-      return "userRecordType=" + info.userRecordType + ";isUpdate=" + info.isUpdate + ";" + newObjectEncoding(info);
+      return "recordID=" + info.id + ";userRecordType=" + info.userRecordType + ";isUpdate=" + info.isUpdate + ";" + newObjectEncoding(info);
    }
 
    // Encoding functions for binding Journal
@@ -2964,7 +2964,16 @@
 
          for (SimpleString prop : properties)
          {
-            buffer.append(prop + "=" + msg.getObjectProperty(prop) + ",");
+            Object value = msg.getObjectProperty(prop);
+            if (value instanceof byte[])
+            {
+               buffer.append(prop + "=" + Arrays.toString((byte[])value) + ",");
+               
+            }
+            else
+            {
+               buffer.append(prop + "=" + value + ",");
+            }
          }
          
          buffer.append("#properties = " + properties.size());