org.xmlBlaster.contrib.replication
Class ReplicationDumper

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

All Implemented Interfaces:

ContribConstants, I_Writer, I_ContribPlugin, I_Update, ReplicationConstants, org.xmlBlaster.util.I_Timeout

public class ReplicationDumper
extends java.lang.Object
implements I_Writer, ReplicationConstants, org.xmlBlaster.util.I_Timeout

Field Summary

protected I_Info

info

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

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	timeout(java.lang.Object userData) You will be notified about the timeout through this method.
void	update(java.lang.String topic, java.io.InputStream is, java.util.Map attrMap) The message received from the MoM or from another source.

Methods inherited from class java.lang.Object

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

Field Detail

info

protected I_Info info

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

shutdown

public void shutdown()
              throws java.lang.Exception

Specified by:

shutdown in interface I_ContribPlugin

Throws:

java.lang.Exception

See Also:

I_Plugin

store

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

Specified by:

store in interface I_Writer

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

timeout

public void timeout(java.lang.Object userData)

Description copied from interface: org.xmlBlaster.util.I_Timeout

You will be notified about the timeout through this method.

Specified by:

timeout in interface org.xmlBlaster.util.I_Timeout

Parameters:

userData - You get bounced back your userData which you passed with Timeout.addTimeoutListener()

See Also:

I_Timeout.timeout(java.lang.Object)