[hornetq-commits] JBoss hornetq SVN: r10276 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal.
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());