org.xmlBlaster.contrib.replication
Class ReplicationDumper

java.lang.Object
  org.xmlBlaster.contrib.replication.ReplicationDumper

All Implemented Interfaces:

ContribConstants, I_ContribPlugin, I_Update, I_Writer, ReplicationConstants

public class ReplicationDumper

extends java.lang.Object

implements I_Writer, ReplicationConstants

Field Summary

private int	backupEvery
private I_Update	callback
private int	count
private java.io.FileWriter	dumper
private java.lang.String	dumperFilename
private java.lang.String	importLocation
protected I_Info	info
private boolean	keepDumpFiles
private static java.util.logging.Logger	log
(package private) I_Mapper	mapper
private I_Parser	parserForOldInUpdates

Fields inherited from interface org.xmlBlaster.contrib.replication.ReplicationConstants

ABSOLUTE_COUNT, ACTION_ATTR, ALREADY_PROCESSED_ATTR, ALTER_ACTION, CATALOG_ATTR, CONTRIB_PERSISTENT_MAP, CREATE_ACTION, DB_ID_ATTR, DELETE_ACTION, DROP_ACTION, DUMP_ACTION, DUMP_CONTENT_ATTR, DUMP_FILENAME, DUMP_POSTFIX, END_OF_TRANSITION, EXCEPTION_ATTR, EXTRA_REPL_KEY_ATTR, GUID_ATTR, INITIAL_DATA_END, INITIAL_DATA_END_TO_REMOTE, INITIAL_DATA_ID, INITIAL_DUMP_AS_XML, INITIAL_FILES_LOCATION, INITIAL_UPDATE_COLLECT, INITIAL_UPDATE_ONLY_REGISTER, INITIAL_UPDATE_START_BATCH, INITIAL_XML_CMD, INSERT_ACTION, KEEP_TRANSACTION_OPEN, MASTER_ATTR, MAX_ENTRIES_ATTR, MESSAGE_SEQ, NUM_OF_TRANSACTIONS, OLD_CONTENT_ATTR, PURPOSE_REPLICATION, REPL_KEY_ATTR, REPL_MANAGER_SESSION, REPL_MANAGER_TOPIC, REPL_PREFIX_DEFAULT, REPL_PREFIX_GROUP_KEY, REPL_PREFIX_KEY, REPL_REQUEST_CANCEL_UPDATE, REPL_REQUEST_RECREATE_TRIGGERS, REPL_REQUEST_UPDATE, REPL_VERSION, REPLICATION_CMD, REPLICATION_FORCE_SENDING, REPLICATION_MAX_ENTRIES_DEFAULT, REPLICATION_MAX_ENTRIES_KEY, REPLICATION_SEND_UNCHANGED_UPDATES, REPLICATION_VERSION, REQUEST_BROADCAST_SQL_TOPIC, REQUEST_CANCEL_UPDATE_TOPIC, REQUEST_INITIAL_DATA_TOPIC, REQUEST_RECREATE_TRIGGERS, RESPONSE_INITIAL_DATA_TOPIC, SCHEMA_ATTR, SIMPLE_MESSAGE, SLAVE_NAME, SQL_TOPIC_ATTR, STATEMENT_ACTION, STATEMENT_ATTR, STATEMENT_ID_ATTR, STATEMENT_PRIO_ATTR, SUPPORTED_VERSIONS, TABLE_NAME_ATTR, TRANSACTION_ATTR, TRANSACTION_SEQ, UPDATE_ACTION, VERSION_ATTR, VERSION_TOKEN

Fields inherited from interface org.xmlBlaster.contrib.ContribConstants

FILE_DATE, FILENAME_ATTR, FILENAME_ATTR_OLD_FASHION, SUBDIR_ATTR, TIMESTAMP_ATTR, TOPIC_NAME

Constructor Summary

ReplicationDumper()

Method Summary

private boolean	checkIfAlreadyProcessed(SqlInfo dbInfo) Checks weather an entry has already been processed, in which case it will not be processed anymore
private void	copyFile(java.lang.String inFile, java.lang.String outFile)
private void	deleteFiles(java.util.Map attrMap)
private void	deleteFiles(java.lang.String filename)
private void	dumperBackup()
private java.lang.String	getCompleteFileName(java.lang.String filename)
java.util.Set	getUsedPropertyKeys() Gets all property keys which may be used by this object.
void	init(I_Info info_)
void	shutdown()
void	store(SqlInfo dbInfo)
void	update(java.lang.String topic, java.io.InputStream is, java.util.Map attrMap) The message received from the MoM or from another source.
private void	updateDump(java.lang.String topic, java.io.InputStream is, java.util.Map attrMap) This is invoked for dump files
private void	updateManualTransfer(java.lang.String topic, java.io.InputStream is, java.util.Map attrMap)

Methods inherited from class java.lang.Object

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

Field Detail

log

private static java.util.logging.Logger log

info

protected I_Info info

mapper

I_Mapper mapper

importLocation

private java.lang.String importLocation

callback

private I_Update callback

keepDumpFiles

private boolean keepDumpFiles

parserForOldInUpdates

private I_Parser parserForOldInUpdates

dumper

private java.io.FileWriter dumper

dumperFilename

private java.lang.String dumperFilename

count

private int count

backupEvery

private int backupEvery

Constructor Detail

ReplicationDumper

public ReplicationDumper()

Method Detail

getUsedPropertyKeys

public java.util.Set getUsedPropertyKeys()

Description copied from interface: I_ContribPlugin

Gets all property keys which may be used by this object.

Specified by:

getUsedPropertyKeys in interface I_ContribPlugin

Returns:

See Also:

I_ContribPlugin.getUsedPropertyKeys()

init

public void init(I_Info info_)
          throws java.lang.Exception

Specified by:

init in interface I_ContribPlugin

Throws:

java.lang.Exception

copyFile

private void copyFile(java.lang.String inFile,
                      java.lang.String outFile)
               throws java.io.IOException

Throws:

java.io.IOException

dumperBackup

private void dumperBackup()

shutdown

public void shutdown()
              throws java.lang.Exception

Specified by:

shutdown in interface I_ContribPlugin

Throws:

java.lang.Exception

See Also:

I_Plugin

checkIfAlreadyProcessed

private boolean checkIfAlreadyProcessed(SqlInfo dbInfo)

Checks weather an entry has already been processed, in which case it will not be processed anymore

Parameters:

dbInfo -

Returns:

store

public void store(SqlInfo dbInfo)
           throws java.lang.Exception

Specified by:

store in interface I_Writer

Throws:

java.lang.Exception

getCompleteFileName

private final java.lang.String getCompleteFileName(java.lang.String filename)

deleteFiles

private void deleteFiles(java.lang.String filename)

deleteFiles

private void deleteFiles(java.util.Map attrMap)

updateDump

private void updateDump(java.lang.String topic,
                        java.io.InputStream is,
                        java.util.Map attrMap)
                 throws java.lang.Exception

This is invoked for dump files

Throws:

java.lang.Exception

updateManualTransfer

private void updateManualTransfer(java.lang.String topic,
                                  java.io.InputStream is,
                                  java.util.Map attrMap)
                           throws java.lang.Exception

Throws:

java.lang.Exception

update

public void update(java.lang.String topic,
                   java.io.InputStream is,
                   java.util.Map attrMap)
            throws java.lang.Exception

Description copied from interface: I_Update

The message received from the MoM or from another source.

Specified by:

update in interface I_Update

Parameters:

topic - The topic name

attrMap - A map with attribute, can be null

Throws:

java.lang.Exception