org.apache.activemq.artemis.core.persistence.impl.journal

Class DescribeJournal

java.lang.Object

org.apache.activemq.artemis.core.persistence.impl.journal.DescribeJournal

public final class DescribeJournal
extends Object

Outputs a String description of the Journals contents.

Meant to be used in debugging.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DescribeJournal.MessageDescribe
static class	DescribeJournal.ReferenceDescribe

Constructor Summary

Constructors

Constructor and Description
DescribeJournal(List<RecordInfo> records, List<PreparedTransactionInfo> preparedTransactions)

Method Summary

Modifier and Type	Method and Description
static void	describeBindingsJournal(File bindingsDir)
static DescribeJournal	describeMessagesJournal(File messagesDir)
List<PreparedTransactionInfo>	getPreparedTransactions()
List<RecordInfo>	getRecords()
protected static PageSubscriptionCounterImpl	lookupCounter(Map<Long,PageSubscriptionCounterImpl> counters, long queueIDForCounter)
static Object	newObjectEncoding(RecordInfo info)
static Object	newObjectEncoding(RecordInfo info, JournalStorageManager storageManager)
protected static void	printCounters(PrintStream out, Map<Long,PageSubscriptionCounterImpl> counters)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DescribeJournal

public DescribeJournal(List<RecordInfo> records,
                       List<PreparedTransactionInfo> preparedTransactions)

Method Detail

getRecords

public List<RecordInfo> getRecords()

getPreparedTransactions

public List<PreparedTransactionInfo> getPreparedTransactions()

describeBindingsJournal

public static void describeBindingsJournal(File bindingsDir)
                                    throws Exception

Throws:

Exception

describeMessagesJournal

public static DescribeJournal describeMessagesJournal(File messagesDir)
                                               throws Exception

Throws:

Exception

printCounters

protected static void printCounters(PrintStream out,
                                    Map<Long,PageSubscriptionCounterImpl> counters)

lookupCounter

protected static PageSubscriptionCounterImpl lookupCounter(Map<Long,PageSubscriptionCounterImpl> counters,
                                                           long queueIDForCounter)

newObjectEncoding

public static Object newObjectEncoding(RecordInfo info)

newObjectEncoding

public static Object newObjectEncoding(RecordInfo info,
                                       JournalStorageManager storageManager)