public class ImportJournal extends Object
importJournal(String, String, String, int, int, String)
If you use the main method, use its arguments as:
JournalDirectory JournalPrefix FileExtension MinFiles FileSize FileOutput
Example:
java -cp hornetq-core.jar org.hornetq.core.journal.impl.ExportJournal /journalDir hornetq-data hq 2 10485760 /tmp/export.dat
Constructor and Description |
---|
ImportJournal() |
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) |
public static void main(String[] arg)
public static void importJournal(String directory, String journalPrefix, String journalSuffix, int minFiles, int fileSize, String fileInput) throws Exception
Exception
public static void importJournal(String directory, String journalPrefix, String journalSuffix, int minFiles, int fileSize, InputStream stream) throws Exception
Exception
public static void importJournal(String directory, String journalPrefix, String journalSuffix, int minFiles, int fileSize, Reader reader) throws Exception
Exception
protected static AtomicInteger getCounter(Long txID, Map<Long,AtomicInteger> txCounters)
protected static RecordInfo parseRecord(Properties properties) throws Exception
Exception
protected static Properties parseLine(String[] splitLine)
Copyright © 2018 JBoss by Red Hat. All rights reserved.