org.hornetq.core.journal.impl

Class ImportJournal

java.lang.Object

org.hornetq.core.journal.impl.ImportJournal

public class ImportJournal
extends Object

Use this class to import the journal data from a listed file. You can use it as a main class or through its native method importJournal(String, String, String, int, int, String) If you use the main method, use it as Example: java -cp hornetq-core.jar org.hornetq.core.journal.impl.ExportJournal /journalDir hornetq-data hq 2 10485760 /tmp/export.dat

Author:

Clebert Suconic

Constructor Summary

Constructors

Constructor and Description
ImportJournal()

Method Summary

Methods

Modifier and Type	Method and Description
protected static AtomicInteger	getCounter(Long txID, Map<Long,AtomicInteger> txCounters)
static void	importJournal(String directory, String journalPrefix, String journalSuffix, int minFiles, int fileSize, InputStream stream)
static void	importJournal(String directory, String journalPrefix, String journalSuffix, int minFiles, int fileSize, Reader reader)
static void	importJournal(String directory, String journalPrefix, String journalSuffix, int minFiles, int fileSize, String fileInput)
static void	main(String[] arg)
protected static Properties	parseLine(String[] splitLine)
protected static RecordInfo	parseRecord(Properties properties)

Methods inherited from class java.lang.Object

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

Constructor Detail

ImportJournal

public ImportJournal()

Method Detail

main

public static void main(String[] arg)

importJournal

public static void importJournal(String directory,
                 String journalPrefix,
                 String journalSuffix,
                 int minFiles,
                 int fileSize,
                 String fileInput)
                          throws Exception

Throws:

Exception

importJournal

public static void importJournal(String directory,
                 String journalPrefix,
                 String journalSuffix,
                 int minFiles,
                 int fileSize,
                 InputStream stream)
                          throws Exception

Throws:

Exception

importJournal

public static void importJournal(String directory,
                 String journalPrefix,
                 String journalSuffix,
                 int minFiles,
                 int fileSize,
                 Reader reader)
                          throws Exception

Throws:

Exception

getCounter

protected static AtomicInteger getCounter(Long txID,
                       Map<Long,AtomicInteger> txCounters)

parseRecord

protected static RecordInfo parseRecord(Properties properties)
                                 throws Exception

Throws:

Exception

parseLine

protected static Properties parseLine(String[] splitLine)