[hornetq-commits] JBoss hornetq SVN: r10269 - in branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence: impl/journal and 1 other directory.
do-not-reply at jboss.org
do-not-reply at jboss.org
Mon Feb 28 17:45:43 EST 2011
Author: clebert.suconic at jboss.com
Date: 2011-02-28 17:45:42 -0500 (Mon, 28 Feb 2011)
New Revision: 10269
Added:
branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/PrintData.java
Modified:
branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/config/PersistedAddressSetting.java
branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/config/PersistedRoles.java
branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/BatchingIDGenerator.java
branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
Log:
Debug information for customer's data
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/config/PersistedAddressSetting.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/config/PersistedAddressSetting.java 2011-02-28 19:19:53 UTC (rev 10268)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/config/PersistedAddressSetting.java 2011-02-28 22:45:42 UTC (rev 10269)
@@ -44,6 +44,20 @@
super();
}
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "PersistedAddressSetting [storeId=" + storeId +
+ ", addressMatch=" +
+ addressMatch +
+ ", setting=" +
+ setting +
+ "]";
+ }
+
/**
* @param addressMatch
* @param setting
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/config/PersistedRoles.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/config/PersistedRoles.java 2011-02-28 19:19:53 UTC (rev 10268)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/config/PersistedRoles.java 2011-02-28 22:45:42 UTC (rev 10269)
@@ -302,6 +302,32 @@
return false;
return true;
}
+
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "PersistedRoles [storeId=" + storeId +
+ ", addressMatch=" +
+ addressMatch +
+ ", sendRoles=" +
+ sendRoles +
+ ", consumeRoles=" +
+ consumeRoles +
+ ", createDurableQueueRoles=" +
+ createDurableQueueRoles +
+ ", deleteDurableQueueRoles=" +
+ deleteDurableQueueRoles +
+ ", createNonDurableQueueRoles=" +
+ createNonDurableQueueRoles +
+ ", deleteNonDurableQueueRoles=" +
+ deleteNonDurableQueueRoles +
+ ", manageRoles=" +
+ manageRoles +
+ "]";
+ }
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/BatchingIDGenerator.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/BatchingIDGenerator.java 2011-02-28 19:19:53 UTC (rev 10268)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/BatchingIDGenerator.java 2011-02-28 22:45:42 UTC (rev 10269)
@@ -135,10 +135,19 @@
// Inner classes -------------------------------------------------
- private static final class IDCounterEncoding implements EncodingSupport
+ static final class IDCounterEncoding implements EncodingSupport
{
long id;
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "IDCounterEncoding [id=" + id + "]";
+ }
+
IDCounterEncoding(final long id)
{
this.id = id;
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-02-28 19:19:53 UTC (rev 10268)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java 2011-02-28 22:45:42 UTC (rev 10269)
@@ -14,15 +14,19 @@
package org.hornetq.core.persistence.impl.journal;
import java.io.File;
+import java.io.PrintStream;
import java.nio.ByteBuffer;
import java.security.AccessController;
import java.security.PrivilegedAction;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.Collection;
import java.util.HashMap;
import java.util.LinkedHashMap;
+import java.util.LinkedList;
import java.util.List;
import java.util.Map;
+import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
@@ -37,6 +41,7 @@
import org.hornetq.api.core.Pair;
import org.hornetq.api.core.SimpleString;
import org.hornetq.core.config.Configuration;
+import org.hornetq.core.config.impl.ConfigurationImpl;
import org.hornetq.core.filter.Filter;
import org.hornetq.core.journal.EncodingSupport;
import org.hornetq.core.journal.IOAsyncTask;
@@ -48,7 +53,10 @@
import org.hornetq.core.journal.SequentialFileFactory;
import org.hornetq.core.journal.TransactionFailureCallback;
import org.hornetq.core.journal.impl.AIOSequentialFileFactory;
+import org.hornetq.core.journal.impl.ExportJournal;
+import org.hornetq.core.journal.impl.JournalFile;
import org.hornetq.core.journal.impl.JournalImpl;
+import org.hornetq.core.journal.impl.JournalReaderCallback;
import org.hornetq.core.journal.impl.NIOSequentialFileFactory;
import org.hornetq.core.logging.Logger;
import org.hornetq.core.message.impl.MessageInternal;
@@ -67,6 +75,7 @@
import org.hornetq.core.persistence.StorageManager;
import org.hornetq.core.persistence.config.PersistedAddressSetting;
import org.hornetq.core.persistence.config.PersistedRoles;
+import org.hornetq.core.persistence.impl.journal.BatchingIDGenerator.IDCounterEncoding;
import org.hornetq.core.postoffice.Binding;
import org.hornetq.core.postoffice.DuplicateIDCache;
import org.hornetq.core.postoffice.PostOffice;
@@ -85,6 +94,7 @@
import org.hornetq.core.transaction.TransactionOperation;
import org.hornetq.core.transaction.TransactionPropertyIndexes;
import org.hornetq.core.transaction.impl.TransactionImpl;
+import org.hornetq.utils.Base64;
import org.hornetq.utils.DataConstants;
import org.hornetq.utils.ExecutorFactory;
import org.hornetq.utils.HornetQThreadFactory;
@@ -107,7 +117,7 @@
private static final long CHECKPOINT_BATCH_SIZE = Integer.MAX_VALUE;
// grouping journal record type
- public static final byte GROUP_RECORD = 41;
+ public static final byte GROUP_RECORD = 20;
// Bindings journal record type
@@ -168,7 +178,7 @@
private final ExecutorFactory executorFactory;
private final Executor executor;
-
+
private ExecutorService singleThreadExecutor;
private final boolean syncTransactional;
@@ -395,12 +405,12 @@
{
OperationContextImpl.setContext(context);
}
-
+
public Executor getSingleThreadExecutor()
{
return singleThreadExecutor;
}
-
+
public OperationContext newSingleThreadContext()
{
return newContext(singleThreadExecutor);
@@ -1324,6 +1334,36 @@
messageJournal.appendDeleteRecordTransactional(txID, recordID);
}
+ public static void describeBindingJournal(final String bindingsDir) throws Exception
+ {
+
+ SequentialFileFactory bindingsFF = new NIOSequentialFileFactory(bindingsDir);
+
+ JournalImpl bindings = new JournalImpl(1024 * 1024, 2, -1, 0, bindingsFF, "hornetq-bindings", "bindings", 1);
+
+ describeJournal(bindingsFF, bindings);
+ }
+
+ public static void describeMessagesJournal(final String messagesDir) throws Exception
+ {
+
+ SequentialFileFactory messagesFF = new NIOSequentialFileFactory(messagesDir);
+
+ // Will use only default values. The load function should adapt to anything different
+ ConfigurationImpl defaultValues = new ConfigurationImpl();
+
+ JournalImpl messagesJournal = new JournalImpl(defaultValues.getJournalFileSize(),
+ defaultValues.getJournalMinFiles(),
+ 0,
+ 0,
+ messagesFF,
+ "hornetq-data",
+ "hq",
+ 1);
+
+ describeJournal(messagesFF, messagesJournal);
+ }
+
public JournalLoadInformation loadBindingJournal(final List<QueueBindingInfo> queueBindingInfos,
final List<GroupingInfo> groupingInfos) throws Exception
{
@@ -1343,12 +1383,8 @@
if (rec == JournalStorageManager.QUEUE_BINDING_RECORD)
{
- PersistentQueueBindingEncoding bindingEncoding = new PersistentQueueBindingEncoding();
+ PersistentQueueBindingEncoding bindingEncoding = newBindingEncoding(id, buffer);
- bindingEncoding.decode(buffer);
-
- bindingEncoding.setId(id);
-
queueBindingInfos.add(bindingEncoding);
}
else if (rec == JournalStorageManager.ID_COUNTER_RECORD)
@@ -1357,23 +1393,17 @@
}
else if (rec == JournalStorageManager.GROUP_RECORD)
{
- GroupingEncoding encoding = new GroupingEncoding();
- encoding.decode(buffer);
- encoding.setId(id);
+ GroupingEncoding encoding = newGroupEncoding(id, buffer);
groupingInfos.add(encoding);
}
else if (rec == JournalStorageManager.ADDRESS_SETTING_RECORD)
{
- PersistedAddressSetting setting = new PersistedAddressSetting();
- setting.decode(buffer);
- setting.setStoreId(id);
+ PersistedAddressSetting setting = newAddressEncoding(id, buffer);
mapPersistedAddressSettings.put(setting.getAddressMatch(), setting);
}
else if (rec == JournalStorageManager.SECURITY_RECORD)
{
- PersistedRoles roles = new PersistedRoles();
- roles.decode(buffer);
- roles.setStoreId(id);
+ PersistedRoles roles = newSecurityRecord(id, buffer);
mapPersistedRoles.put(roles.getAddressMatch(), roles);
}
else
@@ -1402,9 +1432,11 @@
checkAndCreateDir(largeMessagesDirectory, createJournalDir);
cleanupIncompleteFiles();
-
- singleThreadExecutor = Executors.newSingleThreadExecutor(new HornetQThreadFactory("HornetQ-IO-SingleThread", true, getThisClassLoader()));
+ singleThreadExecutor = Executors.newSingleThreadExecutor(new HornetQThreadFactory("HornetQ-IO-SingleThread",
+ true,
+ getThisClassLoader()));
+
bindingsJournal.start();
messageJournal.start();
@@ -1412,7 +1444,6 @@
started = true;
}
-
public synchronized void stop() throws Exception
{
if (!started)
@@ -1429,7 +1460,7 @@
bindingsJournal.stop();
messageJournal.stop();
-
+
singleThreadExecutor.shutdown();
journalLoaded = false;
@@ -1682,7 +1713,7 @@
}
case PAGE_TRANSACTION:
{
-
+
PageTransactionInfo pageTransactionInfo = new PageTransactionInfoImpl();
pageTransactionInfo.decode(buff);
@@ -1695,11 +1726,11 @@
else
{
pageTransactionInfo.setCommitted(false);
-
+
tx.putProperty(TransactionPropertyIndexes.PAGE_TRANSACTION, pageTransactionInfo);
-
+
pagingManager.addTransaction(pageTransactionInfo);
-
+
tx.addOperation(new FinishPageMessageOperation());
}
@@ -1733,7 +1764,10 @@
encoding.position.setRecordID(record.id);
- PageSubscription sub = locateSubscription(encoding.queueID, pageSubscriptions, queueInfos, pagingManager);
+ PageSubscription sub = locateSubscription(encoding.queueID,
+ pageSubscriptions,
+ queueInfos,
+ pagingManager);
if (sub != null)
{
@@ -1851,7 +1885,6 @@
}
}
-
private static ClassLoader getThisClassLoader()
{
return AccessController.doPrivileged(new PrivilegedAction<ClassLoader>()
@@ -1863,7 +1896,6 @@
});
}
-
// Inner Classes
// ----------------------------------------------------------------------------
@@ -1996,6 +2028,15 @@
boolean isCommit;
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "HeuristicCompletionEncoding [xid=" + xid + ", isCommit=" + isCommit + "]";
+ }
+
HeuristicCompletionEncoding(final Xid xid, final boolean isCommit)
{
this.xid = xid;
@@ -2080,10 +2121,13 @@
return clusterName;
}
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
@Override
public String toString()
{
- return id + ":" + groupId + ":" + clusterName;
+ return "GroupingEncoding [id=" + id + ", groupId=" + groupId + ", clusterName=" + clusterName + "]";
}
}
@@ -2101,6 +2145,22 @@
{
}
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "PersistentQueueBindingEncoding [id=" + id +
+ ", name=" +
+ name +
+ ", address=" +
+ address +
+ ", filterString=" +
+ filterString +
+ "]";
+ }
+
public PersistentQueueBindingEncoding(final SimpleString name,
final SimpleString address,
final SimpleString filterString)
@@ -2156,40 +2216,6 @@
}
}
- private static class PersistentIDEncoding implements EncodingSupport
- {
- UUID uuid;
-
- PersistentIDEncoding(final UUID uuid)
- {
- this.uuid = uuid;
- }
-
- PersistentIDEncoding()
- {
- }
-
- public void decode(final HornetQBuffer buffer)
- {
- byte[] bytes = new byte[16];
-
- buffer.readBytes(bytes);
-
- uuid = new UUID(UUID.TYPE_TIME_BASED, bytes);
- }
-
- public void encode(final HornetQBuffer buffer)
- {
- buffer.writeBytes(uuid.asBytes());
- }
-
- public int getEncodeSize()
- {
- return 16;
- }
-
- }
-
private static class LargeMessageEncoding implements EncodingSupport
{
private final LargeServerMessage message;
@@ -2259,6 +2285,16 @@
{
return 8 + 4;
}
+
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "DeliveryCountUpdateEncoding [queueID=" + queueID + ", count=" + count + "]";
+ }
+
}
private static class QueueEncoding implements EncodingSupport
@@ -2290,6 +2326,16 @@
{
return 8;
}
+
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "QueueEncoding [queueID=" + queueID + "]";
+ }
+
}
private static class DeleteEncoding extends QueueEncoding
@@ -2325,6 +2371,15 @@
public int recods;
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "PageUpdateTXEncoding [pageTX=" + pageTX + ", recods=" + recods + "]";
+ }
+
public PageUpdateTXEncoding()
{
}
@@ -2368,6 +2423,15 @@
{
long scheduledDeliveryTime;
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "ScheduledDeliveryEncoding [scheduledDeliveryTime=" + scheduledDeliveryTime + "]";
+ }
+
private ScheduledDeliveryEncoding(final long scheduledDeliveryTime, final long queueID)
{
super(queueID);
@@ -2440,6 +2504,16 @@
{
return SimpleString.sizeofString(address) + DataConstants.SIZE_INT + duplID.length;
}
+
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "DuplicateIDEncoding [address=" + address + ", duplID=" + Arrays.toString(duplID) + "]";
+ }
+
}
private class FinishPageMessageOperation implements TransactionOperation
@@ -2495,6 +2569,15 @@
private static final class PageCountRecord implements EncodingSupport
{
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "PageCountRecord [queueID=" + queueID + ", value=" + value + "]";
+ }
+
PageCountRecord()
{
@@ -2541,6 +2624,15 @@
private static final class PageCountRecordInc implements EncodingSupport
{
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "PageCountRecordInc [queueID=" + queueID + ", value=" + value + "]";
+ }
+
PageCountRecordInc()
{
@@ -2611,6 +2703,15 @@
this.position = new PagePositionImpl();
}
+ /* (non-Javadoc)
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString()
+ {
+ return "CursorAckRecordEncoding [queueID=" + queueID + ", position=" + position + "]";
+ }
+
long queueID;
PagePosition position;
@@ -2681,4 +2782,384 @@
}
}
+
+ private static String describeRecord(RecordInfo info)
+ {
+ return "userRecordType=" + info.userRecordType + ";isUpdate=" + info.isUpdate + ";" + newObjectEncoding(info);
+ }
+
+ // Encoding functions for binding Journal
+
+ private static Object newObjectEncoding(RecordInfo info)
+ {
+ HornetQBuffer buffer = HornetQBuffers.wrappedBuffer(info.data);
+ long id = info.id;
+ int rec = info.getUserRecordType();
+
+ switch (rec)
+ {
+ case ADD_LARGE_MESSAGE:
+
+ LargeServerMessage largeMessage = new LargeServerMessageImpl(null);
+
+ LargeMessageEncoding messageEncoding = new LargeMessageEncoding(largeMessage);
+
+ messageEncoding.decode(buffer);
+
+ return new MessageDescribe(largeMessage);
+
+ case ADD_MESSAGE:
+ ServerMessage message = new ServerMessageImpl(rec, 50);
+
+ message.decode(buffer);
+
+ return new MessageDescribe(message);
+
+ case ADD_REF:
+ {
+ final RefEncoding encoding = new RefEncoding();
+ encoding.decode(buffer);
+ return new Object()
+ {
+ public String toString()
+ {
+ return "AddRef;" + encoding;
+ }
+ };
+ }
+
+ case ACKNOWLEDGE_REF:
+ {
+ final RefEncoding encoding = new RefEncoding();
+ encoding.decode(buffer);
+ return new Object()
+ {
+ public String toString()
+ {
+ return "ACK;" + encoding;
+ }
+ };
+ }
+
+ case UPDATE_DELIVERY_COUNT:
+ {
+ DeliveryCountUpdateEncoding updateDeliveryCount = new DeliveryCountUpdateEncoding();
+ updateDeliveryCount.decode(buffer);
+ return updateDeliveryCount;
+ }
+
+ case PAGE_TRANSACTION:
+ {
+ if (info.isUpdate)
+ {
+ PageUpdateTXEncoding pageUpdate = new PageUpdateTXEncoding();
+
+ pageUpdate.decode(buffer);
+
+ return pageUpdate;
+ }
+ else
+ {
+ PageTransactionInfoImpl pageTransactionInfo = new PageTransactionInfoImpl();
+
+ pageTransactionInfo.decode(buffer);
+
+ pageTransactionInfo.setRecordID(info.id);
+
+ return pageTransactionInfo;
+ }
+ }
+
+ case SET_SCHEDULED_DELIVERY_TIME:
+ {
+ ScheduledDeliveryEncoding encoding = new ScheduledDeliveryEncoding();
+
+ encoding.decode(buffer);
+
+ return encoding;
+ }
+ case DUPLICATE_ID:
+ {
+ DuplicateIDEncoding encoding = new DuplicateIDEncoding();
+
+ encoding.decode(buffer);
+
+ return encoding;
+ }
+ case HEURISTIC_COMPLETION:
+ {
+ HeuristicCompletionEncoding encoding = new HeuristicCompletionEncoding();
+
+ encoding.decode(buffer);
+
+ return encoding;
+ }
+ case ACKNOWLEDGE_CURSOR:
+ {
+ CursorAckRecordEncoding encoding = new CursorAckRecordEncoding();
+
+ encoding.decode(buffer);
+
+ return encoding;
+ }
+ case PAGE_CURSOR_COUNTER_VALUE:
+ {
+ PageCountRecord encoding = new PageCountRecord();
+
+ encoding.decode(buffer);
+
+ return encoding;
+ }
+
+ case PAGE_CURSOR_COUNTER_INC:
+ {
+ PageCountRecordInc encoding = new PageCountRecordInc();
+
+ encoding.decode(buffer);
+
+ return encoding;
+ }
+
+ case JournalStorageManager.QUEUE_BINDING_RECORD:
+ return newBindingEncoding(id, buffer);
+
+ case JournalStorageManager.ID_COUNTER_RECORD:
+ IDCounterEncoding idReturn = new IDCounterEncoding();
+
+ idReturn.decode(buffer);
+
+ return idReturn;
+
+ case JournalStorageManager.GROUP_RECORD:
+ return newGroupEncoding(id, buffer);
+
+ case JournalStorageManager.ADDRESS_SETTING_RECORD:
+ return newAddressEncoding(id, buffer);
+
+ case JournalStorageManager.SECURITY_RECORD:
+ return newSecurityRecord(id, buffer);
+
+ default:
+ return null;
+ }
+ }
+
+ private static class MessageDescribe
+ {
+ public MessageDescribe(Message msg)
+ {
+ this.msg = msg;
+ }
+
+ Message msg;
+
+ public String toString()
+ {
+ StringBuffer buffer = new StringBuffer();
+ buffer.append(msg.isLargeMessage() ? "LargeMessage(" : "Message(");
+ buffer.append("messageID=" + msg.getMessageID());
+ buffer.append(";properties=[");
+
+ Set<SimpleString> properties = msg.getPropertyNames();
+
+ for (SimpleString prop : properties)
+ {
+ buffer.append(prop + "=" + msg.getObjectProperty(prop) + ",");
+ }
+
+ buffer.append("#properties = " + properties.size());
+
+ buffer.append("]");
+
+ buffer.append(" - " + msg.toString());
+
+ return buffer.toString();
+ }
+
+ }
+
+ /**
+ * @param id
+ * @param buffer
+ * @return
+ */
+ protected static PersistedRoles newSecurityRecord(long id, HornetQBuffer buffer)
+ {
+ PersistedRoles roles = new PersistedRoles();
+ roles.decode(buffer);
+ roles.setStoreId(id);
+ return roles;
+ }
+
+ /**
+ * @param id
+ * @param buffer
+ * @return
+ */
+ protected static PersistedAddressSetting newAddressEncoding(long id, HornetQBuffer buffer)
+ {
+ PersistedAddressSetting setting = new PersistedAddressSetting();
+ setting.decode(buffer);
+ setting.setStoreId(id);
+ return setting;
+ }
+
+ /**
+ * @param id
+ * @param buffer
+ * @return
+ */
+ protected static GroupingEncoding newGroupEncoding(long id, HornetQBuffer buffer)
+ {
+ GroupingEncoding encoding = new GroupingEncoding();
+ encoding.decode(buffer);
+ encoding.setId(id);
+ return encoding;
+ }
+
+ /**
+ * @param id
+ * @param buffer
+ * @return
+ */
+ protected static PersistentQueueBindingEncoding newBindingEncoding(long id, HornetQBuffer buffer)
+ {
+ PersistentQueueBindingEncoding bindingEncoding = new PersistentQueueBindingEncoding();
+
+ bindingEncoding.decode(buffer);
+
+ bindingEncoding.setId(id);
+ return bindingEncoding;
+ }
+
+ private static String encode(final byte[] data)
+ {
+ return Base64.encodeBytes(data, 0, data.length, Base64.DONT_BREAK_LINES | Base64.URL_SAFE);
+ }
+
+ /**
+ * @param fileFactory
+ * @param journal
+ * @throws Exception
+ */
+ protected static void describeJournal(SequentialFileFactory fileFactory, JournalImpl journal) throws Exception
+ {
+ List<JournalFile> files = journal.orderFiles();
+
+ final PrintStream out = System.out;
+
+ for (JournalFile file : files)
+ {
+ out.println("#" + file);
+
+ JournalImpl.readJournalFile(fileFactory, file, new JournalReaderCallback()
+ {
+
+ public void onReadUpdateRecordTX(final long transactionID, final RecordInfo recordInfo) throws Exception
+ {
+ out.println("operation at UpdateTX,txID@" + transactionID + "," + describeRecord(recordInfo));
+ }
+
+ public void onReadUpdateRecord(final RecordInfo recordInfo) throws Exception
+ {
+ out.println("operation at Update," + describeRecord(recordInfo));
+ }
+
+ public void onReadRollbackRecord(final long transactionID) throws Exception
+ {
+ out.println("operation at Rollback,txID@" + transactionID);
+ }
+
+ public void onReadPrepareRecord(final long transactionID, final byte[] extraData, final int numberOfRecords) throws Exception
+ {
+ out.println("operation at Prepare,txID@" + transactionID +
+ ",numberOfRecords@" +
+ numberOfRecords +
+ ",extraData@" +
+ encode(extraData));
+ }
+
+ public void onReadDeleteRecordTX(final long transactionID, final RecordInfo recordInfo) throws Exception
+ {
+ out.println("operation at DeleteRecordTX,txID@" + transactionID + "," + describeRecord(recordInfo));
+ }
+
+ public void onReadDeleteRecord(final long recordID) throws Exception
+ {
+ out.println("operation at DeleteRecord,id@" + recordID);
+ }
+
+ public void onReadCommitRecord(final long transactionID, final int numberOfRecords) throws Exception
+ {
+ out.println("operation at Commit,txID@" + transactionID + ",numberOfRecords@" + numberOfRecords);
+ }
+
+ public void onReadAddRecordTX(final long transactionID, final RecordInfo recordInfo) throws Exception
+ {
+ out.println("operation at AddRecordTX,txID@" + transactionID + "," + describeRecord(recordInfo));
+ }
+
+ public void onReadAddRecord(final RecordInfo recordInfo) throws Exception
+ {
+ out.println("operation at AddRecord," + describeRecord(recordInfo));
+ }
+
+ public void markAsDataFile(final JournalFile file)
+ {
+ }
+ });
+ }
+
+ out.println();
+
+ out.println("### Surviving Records Summary ###");
+
+ List<RecordInfo> records = new LinkedList<RecordInfo>();
+ List<PreparedTransactionInfo> preparedTransactions = new LinkedList<PreparedTransactionInfo>();
+
+ journal.start();
+
+ journal.load(records, preparedTransactions, new TransactionFailureCallback()
+ {
+
+ public void failedTransaction(long transactionID, List<RecordInfo> records, List<RecordInfo> recordsToDelete)
+ {
+ out.println("Transaction " + transactionID + " failed with these records:");
+ for (RecordInfo info : records)
+ {
+ out.println("- " + describeRecord(info));
+ }
+
+ for (RecordInfo info : recordsToDelete)
+ {
+ out.println("- " + describeRecord(info) + " <marked to delete>");
+ }
+
+ }
+ });
+
+ for (RecordInfo info : records)
+ {
+ System.out.println(describeRecord(info));
+ }
+
+ out.println("### Prepared TX ###");
+
+ for (PreparedTransactionInfo tx : preparedTransactions)
+ {
+ System.out.println(tx.id);
+ for (RecordInfo info : tx.records)
+ {
+ out.println("- " + describeRecord(info));
+ }
+
+ for (RecordInfo info : tx.recordsToDelete)
+ {
+ out.println("- " + describeRecord(info) + " <marked to delete>");
+ }
+ }
+
+ journal.stop();
+ }
+
}
Added: branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/PrintData.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/PrintData.java (rev 0)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/persistence/impl/journal/PrintData.java 2011-02-28 22:45:42 UTC (rev 10269)
@@ -0,0 +1,80 @@
+/*
+ * Copyright 2010 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied. See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.hornetq.core.persistence.impl.journal;
+
+/**
+ * A PrintData
+ *
+ * @author clebertsuconic
+ *
+ *
+ */
+public class PrintData
+{
+
+ // Constants -----------------------------------------------------
+
+ // Attributes ----------------------------------------------------
+
+ // Static --------------------------------------------------------
+
+ // Constructors --------------------------------------------------
+
+ // Public --------------------------------------------------------
+
+
+ public static void main(String arg[])
+ {
+ if (arg.length != 2)
+ {
+ System.out.println("Use: java -cp hornetq-core.jar <bindings directory> <message directory>");
+ System.exit(-1);
+ }
+
+ System.out.println("********************************************");
+ System.out.println("B I N D I N G S J O U R N A L");
+ System.out.println("********************************************");
+
+ try
+ {
+ JournalStorageManager.describeBindingJournal(arg[0]);
+ }
+ catch (Exception e)
+ {
+ e.printStackTrace();
+ }
+
+ System.out.println("********************************************");
+ System.out.println("M E S S A G E S J O U R N A L");
+ System.out.println("********************************************");
+
+ try
+ {
+ JournalStorageManager.describeMessagesJournal(arg[1]);
+ }
+ catch (Exception e)
+ {
+ e.printStackTrace();
+ }
+ }
+
+ // Package protected ---------------------------------------------
+
+ // Protected -----------------------------------------------------
+
+ // Private -------------------------------------------------------
+
+ // Inner classes -------------------------------------------------
+
+}
More information about the hornetq-commits
mailing list