Author: clebert.suconic(a)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());