org.hornetq.core.journal.impl

Class JournalImpl

java.lang.Object

org.hornetq.core.journal.impl.JournalImpl

All Implemented Interfaces:

JournalRecordProvider, Journal, TestableJournal, HornetQComponent

public class JournalImpl
extends Object
implements TestableJournal, JournalRecordProvider

A circular log implementation.

Look at load(LoaderCallback) for the file layout

Author:

Tim Fox, Clebert Suconic

Field Summary

Fields

Modifier and Type	Field and Description
static byte	ADD_RECORD
static byte	ADD_RECORD_TX
static int	BASIC_SIZE
static byte	COMMIT_RECORD
static byte	DELETE_RECORD
static byte	DELETE_RECORD_TX
static byte	FILL_CHARACTER
static int	FORMAT_VERSION
static int	MIN_FILE_SIZE
static byte	PREPARE_RECORD
static byte	ROLLBACK_RECORD
static int	SIZE_ADD_RECORD
static int	SIZE_ADD_RECORD_TX
static int	SIZE_COMMIT_RECORD
static int	SIZE_COMPLETE_TRANSACTION_RECORD
static int	SIZE_DELETE_RECORD
static int	SIZE_DELETE_RECORD_TX
static int	SIZE_HEADER
static int	SIZE_PREPARE_RECORD
static int	SIZE_ROLLBACK_RECORD
static byte	UPDATE_RECORD
static byte	UPDATE_RECORD_TX

Constructor Summary

Constructors

Constructor and Description
JournalImpl(int fileSize, int minFiles, int compactMinFiles, int compactPercentage, SequentialFileFactory fileFactory, String filePrefix, String fileExtension, int maxAIO)
JournalImpl(int fileSize, int minFiles, int compactMinFiles, int compactPercentage, SequentialFileFactory fileFactory, String filePrefix, String fileExtension, int maxAIO, int userVersion)

Method Summary

Methods

Modifier and Type	Method and Description
void	appendAddRecord(long id, byte recordType, byte[] record, boolean sync)
void	appendAddRecord(long id, byte recordType, byte[] record, boolean sync, IOCompletion callback)
void	appendAddRecord(long id, byte recordType, EncodingSupport record, boolean sync)
void	appendAddRecord(long id, byte recordType, EncodingSupport record, boolean sync, IOCompletion callback)
void	appendAddRecordTransactional(long txID, long id, byte recordType, byte[] record)
void	appendAddRecordTransactional(long txID, long id, byte recordType, EncodingSupport record)
void	appendCommitRecord(long txID, boolean sync)
void	appendCommitRecord(long txID, boolean sync, IOCompletion callback)
void	appendCommitRecord(long txID, boolean sync, IOCompletion callback, boolean lineUpContext) A transaction record (Commit or Prepare), will hold the number of elements the transaction has on each file.
void	appendDeleteRecord(long id, boolean sync)
void	appendDeleteRecord(long id, boolean sync, IOCompletion callback)
void	appendDeleteRecordTransactional(long txID, long id)
void	appendDeleteRecordTransactional(long txID, long id, byte[] record)
void	appendDeleteRecordTransactional(long txID, long id, EncodingSupport record)
void	appendPrepareRecord(long txID, byte[] transactionData, boolean sync)
void	appendPrepareRecord(long txID, byte[] transactionData, boolean sync, IOCompletion completion)
void	appendPrepareRecord(long txID, EncodingSupport transactionData, boolean sync) If the system crashed after a prepare was called, it should store information that is required to bring the transaction back to a state it could be committed.
void	appendPrepareRecord(long txID, EncodingSupport transactionData, boolean sync, IOCompletion callback) If the system crashed after a prepare was called, it should store information that is required to bring the transaction back to a state it could be committed.
void	appendRollbackRecord(long txID, boolean sync)
void	appendRollbackRecord(long txID, boolean sync, IOCompletion callback)
void	appendUpdateRecord(long id, byte recordType, byte[] record, boolean sync)
void	appendUpdateRecord(long id, byte recordType, byte[] record, boolean sync, IOCompletion callback)
void	appendUpdateRecord(long id, byte recordType, EncodingSupport record, boolean sync)
void	appendUpdateRecord(long id, byte recordType, EncodingSupport record, boolean sync, IOCompletion callback)
void	appendUpdateRecordTransactional(long txID, long id, byte recordType, byte[] record)
void	appendUpdateRecordTransactional(long txID, long id, byte recordType, EncodingSupport record)
boolean	checkReclaimStatus() This method is called automatically when a new file is opened.
protected void	compact() Note: This method can't be called from the main executor, as it will invoke other methods depending on it.
protected SequentialFile	createControlFile(List<JournalFile> files, List<JournalFile> newFiles, Pair<String,String> cleanupRename)
String	debug()
void	debugWait() Method for use on testcases.
protected void	deleteControlFile(SequentialFile controlFile)
void	forceMoveNextFile()
int	getAlignment()
JournalCompactor	getCompactor()
JournalFile	getCurrentFile()
JournalFile[]	getDataFiles()
int	getDataFilesCount()
String	getFileExtension()
String	getFilePrefix()
int	getFileSize()
int	getFreeFilesCount()
int	getIDMapSize()
int	getMaxAIO()
int	getMinFiles()
int	getNumberOfRecords()
int	getOpenedFilesCount()
Map<Long,JournalRecord>	getRecords()
int	getUserVersion()
static int	initFileHeader(SequentialFileFactory fileFactory, SequentialFile sequentialFile, int userVersion, long fileID)
boolean	isAutoReclaim()
boolean	isStarted()
void	lineUpContex(IOCompletion callback)
JournalLoadInformation	load(List<RecordInfo> committedRecords, List<PreparedTransactionInfo> preparedTransactions, TransactionFailureCallback failureCallback)
JournalLoadInformation	load(List<RecordInfo> committedRecords, List<PreparedTransactionInfo> preparedTransactions, TransactionFailureCallback failureCallback, boolean changeData)
JournalLoadInformation	load(LoaderCallback loadManager) Load data accordingly to the record layouts
JournalLoadInformation	load(LoaderCallback loadManager, boolean changeData)
JournalLoadInformation	loadInternalOnly() Load internal data structures and not expose any data.
protected void	onCompactDone() This is an interception point for testcases, when the compacted files are written, before replacing the data structures
protected void	onCompactLock() This is an interception point for testcases, when the compacted files are written, to be called as soon as the compactor gets a writeLock
protected void	onCompactStart() This is an interception point for testcases, when the compacted files are written, before replacing the data structures
List<JournalFile>	orderFiles() this method is used internally only however tools may use it to maintenance.
void	perfBlast(int pages)
static int	readJournalFile(SequentialFileFactory fileFactory, JournalFile file, JournalReaderCallback reader) this method is used internally only however tools may use it to maintenance.
protected static String	renameExtensionFile(String name, String extension)
protected void	renameFiles(List<JournalFile> oldFiles, List<JournalFile> newFiles) being protected as testcases can override this method
void	runDirectJournalBlast()
void	setAutoReclaim(boolean autoReclaim)
void	start()
void	stop()
void	testCompact()
static void	writeHeader(HornetQBuffer buffer, int userVersion, long fileID)

Methods inherited from class java.lang.Object

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

Field Detail

FORMAT_VERSION

public static final int FORMAT_VERSION

See Also:

Constant Field Values

MIN_FILE_SIZE

public static final int MIN_FILE_SIZE

See Also:

Constant Field Values

SIZE_HEADER

public static final int SIZE_HEADER

See Also:

Constant Field Values

BASIC_SIZE

public static final int BASIC_SIZE

See Also:

Constant Field Values

SIZE_ADD_RECORD

public static final int SIZE_ADD_RECORD

See Also:

Constant Field Values

ADD_RECORD

public static final byte ADD_RECORD

See Also:

Constant Field Values

UPDATE_RECORD

public static final byte UPDATE_RECORD

See Also:

Constant Field Values

SIZE_ADD_RECORD_TX

public static final int SIZE_ADD_RECORD_TX

See Also:

Constant Field Values

ADD_RECORD_TX

public static final byte ADD_RECORD_TX

See Also:

Constant Field Values

UPDATE_RECORD_TX

public static final byte UPDATE_RECORD_TX

See Also:

Constant Field Values

SIZE_DELETE_RECORD_TX

public static final int SIZE_DELETE_RECORD_TX

See Also:

Constant Field Values

DELETE_RECORD_TX

public static final byte DELETE_RECORD_TX

See Also:

Constant Field Values

SIZE_DELETE_RECORD

public static final int SIZE_DELETE_RECORD

See Also:

Constant Field Values

DELETE_RECORD

public static final byte DELETE_RECORD

See Also:

Constant Field Values

SIZE_COMPLETE_TRANSACTION_RECORD

public static final int SIZE_COMPLETE_TRANSACTION_RECORD

See Also:

Constant Field Values

SIZE_PREPARE_RECORD

public static final int SIZE_PREPARE_RECORD

See Also:

Constant Field Values

PREPARE_RECORD

public static final byte PREPARE_RECORD

See Also:

Constant Field Values

SIZE_COMMIT_RECORD

public static final int SIZE_COMMIT_RECORD

See Also:

Constant Field Values

COMMIT_RECORD

public static final byte COMMIT_RECORD

See Also:

Constant Field Values

SIZE_ROLLBACK_RECORD

public static final int SIZE_ROLLBACK_RECORD

See Also:

Constant Field Values

ROLLBACK_RECORD

public static final byte ROLLBACK_RECORD

See Also:

Constant Field Values

FILL_CHARACTER

public static final byte FILL_CHARACTER

See Also:

Constant Field Values

Constructor Detail

JournalImpl

public JournalImpl(int fileSize,
           int minFiles,
           int compactMinFiles,
           int compactPercentage,
           SequentialFileFactory fileFactory,
           String filePrefix,
           String fileExtension,
           int maxAIO)

JournalImpl

public JournalImpl(int fileSize,
           int minFiles,
           int compactMinFiles,
           int compactPercentage,
           SequentialFileFactory fileFactory,
           String filePrefix,
           String fileExtension,
           int maxAIO,
           int userVersion)

Method Detail

runDirectJournalBlast

public void runDirectJournalBlast()
                           throws Exception

Specified by:

runDirectJournalBlast in interface Journal

Throws:

Exception

getRecords

public Map<Long,JournalRecord> getRecords()

Specified by:

getRecords in interface JournalRecordProvider

getCurrentFile

public JournalFile getCurrentFile()

Specified by:

getCurrentFile in interface TestableJournal

getCompactor

public JournalCompactor getCompactor()

Specified by:

getCompactor in interface JournalRecordProvider

orderFiles

public List<JournalFile> orderFiles()
                             throws Exception

this method is used internally only however tools may use it to maintenance. It won't be part of the interface as the tools should be specific to the implementation

Throws:

Exception

readJournalFile

public static int readJournalFile(SequentialFileFactory fileFactory,
                  JournalFile file,
                  JournalReaderCallback reader)
                           throws Exception

this method is used internally only however tools may use it to maintenance.

Throws:

Exception

appendAddRecord

public void appendAddRecord(long id,
                   byte recordType,
                   byte[] record,
                   boolean sync)
                     throws Exception

Specified by:

appendAddRecord in interface Journal

Throws:

Exception

appendAddRecord

public void appendAddRecord(long id,
                   byte recordType,
                   byte[] record,
                   boolean sync,
                   IOCompletion callback)
                     throws Exception

Specified by:

appendAddRecord in interface Journal

Throws:

Exception

appendAddRecord

public void appendAddRecord(long id,
                   byte recordType,
                   EncodingSupport record,
                   boolean sync)
                     throws Exception

Specified by:

appendAddRecord in interface Journal

Throws:

Exception

appendAddRecord

public void appendAddRecord(long id,
                   byte recordType,
                   EncodingSupport record,
                   boolean sync,
                   IOCompletion callback)
                     throws Exception

Specified by:

appendAddRecord in interface Journal

Throws:

Exception

appendUpdateRecord

public void appendUpdateRecord(long id,
                      byte recordType,
                      byte[] record,
                      boolean sync)
                        throws Exception

Specified by:

appendUpdateRecord in interface Journal

Throws:

Exception

appendUpdateRecord

public void appendUpdateRecord(long id,
                      byte recordType,
                      byte[] record,
                      boolean sync,
                      IOCompletion callback)
                        throws Exception

Specified by:

appendUpdateRecord in interface Journal

Throws:

Exception

appendUpdateRecord

public void appendUpdateRecord(long id,
                      byte recordType,
                      EncodingSupport record,
                      boolean sync)
                        throws Exception

Specified by:

appendUpdateRecord in interface Journal

Throws:

Exception

appendUpdateRecord

public void appendUpdateRecord(long id,
                      byte recordType,
                      EncodingSupport record,
                      boolean sync,
                      IOCompletion callback)
                        throws Exception

Specified by:

appendUpdateRecord in interface Journal

Throws:

Exception

appendDeleteRecord

public void appendDeleteRecord(long id,
                      boolean sync)
                        throws Exception

Specified by:

appendDeleteRecord in interface Journal

Throws:

Exception

appendDeleteRecord

public void appendDeleteRecord(long id,
                      boolean sync,
                      IOCompletion callback)
                        throws Exception

Specified by:

appendDeleteRecord in interface Journal

Throws:

Exception

appendAddRecordTransactional

public void appendAddRecordTransactional(long txID,
                                long id,
                                byte recordType,
                                byte[] record)
                                  throws Exception

Specified by:

appendAddRecordTransactional in interface Journal

Throws:

Exception

appendAddRecordTransactional

public void appendAddRecordTransactional(long txID,
                                long id,
                                byte recordType,
                                EncodingSupport record)
                                  throws Exception

Specified by:

appendAddRecordTransactional in interface Journal

Throws:

Exception

appendUpdateRecordTransactional

public void appendUpdateRecordTransactional(long txID,
                                   long id,
                                   byte recordType,
                                   byte[] record)
                                     throws Exception

Specified by:

appendUpdateRecordTransactional in interface Journal

Throws:

Exception

appendUpdateRecordTransactional

public void appendUpdateRecordTransactional(long txID,
                                   long id,
                                   byte recordType,
                                   EncodingSupport record)
                                     throws Exception

Specified by:

appendUpdateRecordTransactional in interface Journal

Throws:

Exception

appendDeleteRecordTransactional

public void appendDeleteRecordTransactional(long txID,
                                   long id,
                                   byte[] record)
                                     throws Exception

Specified by:

appendDeleteRecordTransactional in interface Journal

Throws:

Exception

appendDeleteRecordTransactional

public void appendDeleteRecordTransactional(long txID,
                                   long id,
                                   EncodingSupport record)
                                     throws Exception

Specified by:

appendDeleteRecordTransactional in interface Journal

Throws:

Exception

appendDeleteRecordTransactional

public void appendDeleteRecordTransactional(long txID,
                                   long id)
                                     throws Exception

Specified by:

appendDeleteRecordTransactional in interface Journal

Throws:

Exception

appendPrepareRecord

public void appendPrepareRecord(long txID,
                       byte[] transactionData,
                       boolean sync,
                       IOCompletion completion)
                         throws Exception

Specified by:

appendPrepareRecord in interface Journal

Throws:

Exception

appendPrepareRecord

public void appendPrepareRecord(long txID,
                       byte[] transactionData,
                       boolean sync)
                         throws Exception

Specified by:

appendPrepareRecord in interface Journal

Throws:

Exception

appendPrepareRecord

public void appendPrepareRecord(long txID,
                       EncodingSupport transactionData,
                       boolean sync)
                         throws Exception

Description copied from interface: Journal

If the system crashed after a prepare was called, it should store information that is required to bring the transaction back to a state it could be committed.

transactionData allows you to store any other supporting user-data related to the transaction

Specified by:

appendPrepareRecord in interface Journal

transactionData - - extra user data for the prepare

Throws:

Exception

appendPrepareRecord

public void appendPrepareRecord(long txID,
                       EncodingSupport transactionData,
                       boolean sync,
                       IOCompletion callback)
                         throws Exception

If the system crashed after a prepare was called, it should store information that is required to bring the transaction back to a state it could be committed.

transactionData allows you to store any other supporting user-data related to the transaction

This method also uses the same logic applied on appendCommitRecord(long, boolean)

Specified by:

appendPrepareRecord in interface Journal

Parameters:

txID -

transactionData - extra user data for the prepare

Throws:

Exception

appendCommitRecord

public void appendCommitRecord(long txID,
                      boolean sync)
                        throws Exception

Specified by:

appendCommitRecord in interface Journal

Throws:

Exception

lineUpContex

public void lineUpContex(IOCompletion callback)

Specified by:

lineUpContex in interface Journal

appendCommitRecord

public void appendCommitRecord(long txID,
                      boolean sync,
                      IOCompletion callback)
                        throws Exception

Specified by:

appendCommitRecord in interface Journal

Throws:

Exception

appendCommitRecord

public void appendCommitRecord(long txID,
                      boolean sync,
                      IOCompletion callback,
                      boolean lineUpContext)
                        throws Exception

A transaction record (Commit or Prepare), will hold the number of elements the transaction has on each file.

For example, a transaction was spread along 3 journal files with 10 pendingTransactions on each file. (What could happen if there are too many pendingTransactions, or if an user event delayed pendingTransactions to come in time to a single file).

The element-summary will then have

FileID1, 10

FileID2, 10

FileID3, 10

During the load, the transaction needs to have 30 pendingTransactions spread across the files as originally written.

If for any reason there are missing pendingTransactions, that means the transaction was not completed and we should ignore the whole transaction

We can't just use a global counter as reclaiming could delete files after the transaction was successfully committed. That also means not having a whole file on journal-reload doesn't mean we have to invalidate the transaction

Specified by:

appendCommitRecord in interface Journal

Throws:

Exception

appendRollbackRecord

public void appendRollbackRecord(long txID,
                        boolean sync)
                          throws Exception

Specified by:

appendRollbackRecord in interface Journal

Throws:

Exception

appendRollbackRecord

public void appendRollbackRecord(long txID,
                        boolean sync,
                        IOCompletion callback)
                          throws Exception

Specified by:

appendRollbackRecord in interface Journal

Throws:

Exception

getAlignment

public int getAlignment()
                 throws Exception

Specified by:

getAlignment in interface Journal

Throws:

Exception

loadInternalOnly

public JournalLoadInformation loadInternalOnly()
                                        throws Exception

Description copied from interface: Journal

Load internal data structures and not expose any data. This is only useful if you're using the journal but not interested on the current data. Useful in situations where the journal is being replicated, copied... etc.

Specified by:

loadInternalOnly in interface Journal

Throws:

Exception

load

public JournalLoadInformation load(List<RecordInfo> committedRecords,
                          List<PreparedTransactionInfo> preparedTransactions,
                          TransactionFailureCallback failureCallback)
                            throws Exception

Specified by:

load in interface Journal

Throws:

Exception

load

public JournalLoadInformation load(List<RecordInfo> committedRecords,
                          List<PreparedTransactionInfo> preparedTransactions,
                          TransactionFailureCallback failureCallback,
                          boolean changeData)
                            throws Exception

Throws:

Exception

See Also:

load(LoaderCallback)

testCompact

public void testCompact()
                 throws Exception

Specified by:

testCompact in interface TestableJournal

Throws:

Exception

compact

protected void compact()
                throws Exception

Note: This method can't be called from the main executor, as it will invoke other methods depending on it. Note: only synchronized methods on journal are methods responsible for the life-cycle such as stop, start records will still come as this is being executed

Throws:

Exception

load

public JournalLoadInformation load(LoaderCallback loadManager)
                            throws Exception

Load data accordingly to the record layouts

Basic record layout:

Field Name	Size
RecordType	Byte (1)
FileID	Integer (4 bytes)
Compactor Counter	1 byte
TransactionID (if record is transactional)	Long (8 bytes)
RecordID	Long (8 bytes)
BodySize(Add, update and delete)	Integer (4 bytes)
UserDefinedRecordType (If add/update only)	Byte (1)
RecordBody	Byte Array (size=BodySize)
Check Size	Integer (4 bytes)

The check-size is used to validate if the record is valid and complete

Commit/Prepare record layout:

Field Name	Size
RecordType	Byte (1)
FileID	Integer (4 bytes)
Compactor Counter	1 byte
TransactionID (if record is transactional)	Long (8 bytes)
ExtraDataLength (Prepares only)	Integer (4 bytes)
Number Of Files (N)	Integer (4 bytes)
ExtraDataBytes	Bytes (sized by ExtraDataLength)
* FileID(n)	Integer (4 bytes)
* NumberOfElements(n)	Integer (4 bytes)
CheckSize	Integer (4 bytes)

* FileID and NumberOfElements are the transaction summary, and they will be repeated (N)umberOfFiles times

Specified by:

load in interface Journal

Throws:

Exception

load

public JournalLoadInformation load(LoaderCallback loadManager,
                          boolean changeData)
                            throws Exception

Throws:

Exception

checkReclaimStatus

public boolean checkReclaimStatus()
                           throws Exception

Description copied from interface: TestableJournal

This method is called automatically when a new file is opened.

Specified by:

checkReclaimStatus in interface TestableJournal

Returns:

true if cleanup was called

Throws:

Exception

setAutoReclaim

public void setAutoReclaim(boolean autoReclaim)

Specified by:

setAutoReclaim in interface TestableJournal

isAutoReclaim

public boolean isAutoReclaim()

Specified by:

isAutoReclaim in interface TestableJournal

debug

public String debug()
             throws Exception

Specified by:

debug in interface TestableJournal

Throws:

Exception

debugWait

public void debugWait()
               throws Exception

Method for use on testcases. It will call waitComplete on every transaction, so any assertions on the file system will be correct after this

Specified by:

debugWait in interface TestableJournal

Throws:

Exception

getDataFilesCount

public int getDataFilesCount()

Specified by:

getDataFilesCount in interface TestableJournal

getDataFiles

public JournalFile[] getDataFiles()

Specified by:

getDataFiles in interface TestableJournal

getFreeFilesCount

public int getFreeFilesCount()

Specified by:

getFreeFilesCount in interface TestableJournal

getOpenedFilesCount

public int getOpenedFilesCount()

Specified by:

getOpenedFilesCount in interface TestableJournal

getIDMapSize

public int getIDMapSize()

Specified by:

getIDMapSize in interface TestableJournal

getFileSize

public int getFileSize()

Specified by:

getFileSize in interface TestableJournal

getMinFiles

public int getMinFiles()

Specified by:

getMinFiles in interface TestableJournal

getFilePrefix

public String getFilePrefix()

Specified by:

getFilePrefix in interface TestableJournal

getFileExtension

public String getFileExtension()

Specified by:

getFileExtension in interface TestableJournal

getMaxAIO

public int getMaxAIO()

Specified by:

getMaxAIO in interface TestableJournal

getUserVersion

public int getUserVersion()

Specified by:

getUserVersion in interface Journal

forceMoveNextFile

public void forceMoveNextFile()
                       throws Exception

Specified by:

forceMoveNextFile in interface TestableJournal

Throws:

Exception

perfBlast

public void perfBlast(int pages)
               throws Exception

Specified by:

perfBlast in interface Journal

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

start

public void start()

Specified by:

start in interface HornetQComponent

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

getNumberOfRecords

public int getNumberOfRecords()

Specified by:

getNumberOfRecords in interface Journal

createControlFile

protected SequentialFile createControlFile(List<JournalFile> files,
                               List<JournalFile> newFiles,
                               Pair<String,String> cleanupRename)
                                    throws Exception

Throws:

Exception

deleteControlFile

protected void deleteControlFile(SequentialFile controlFile)
                          throws Exception

Throws:

Exception

renameFiles

protected void renameFiles(List<JournalFile> oldFiles,
               List<JournalFile> newFiles)
                    throws Exception

being protected as testcases can override this method

Throws:

Exception

renameExtensionFile

protected static String renameExtensionFile(String name,
                         String extension)

Parameters:

name -

Returns:

onCompactStart

protected void onCompactStart()
                       throws Exception

This is an interception point for testcases, when the compacted files are written, before replacing the data structures

Throws:

Exception

onCompactLock

protected void onCompactLock()
                      throws Exception

This is an interception point for testcases, when the compacted files are written, to be called as soon as the compactor gets a writeLock

Throws:

Exception

onCompactDone

protected void onCompactDone()

This is an interception point for testcases, when the compacted files are written, before replacing the data structures

initFileHeader

public static int initFileHeader(SequentialFileFactory fileFactory,
                 SequentialFile sequentialFile,
                 int userVersion,
                 long fileID)
                          throws Exception

Parameters:

fileID -

sequentialFile -

Throws:

Exception

writeHeader

public static void writeHeader(HornetQBuffer buffer,
               int userVersion,
               long fileID)

Parameters:

buffer -

userVersion -

fileID -