org.jumpmind.symmetric.route

Class TPSRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

org.jumpmind.symmetric.route.AbstractFileParsingRouter

org.jumpmind.symmetric.route.TPSRouter

All Implemented Interfaces:

org.jumpmind.extension.IBuiltInExtensionPoint, org.jumpmind.extension.IExtensionPoint, IDataRouter

public class TPSRouter
extends AbstractFileParsingRouter
implements IDataRouter, org.jumpmind.extension.IBuiltInExtensionPoint

Field Summary

Fields inherited from class org.jumpmind.symmetric.route.AbstractFileParsingRouter

EXTERNAL_DATA_FILE_DATA_ID, EXTERNAL_DATA_ROUTER_KEY, EXTERNAL_DATA_TRIGGER_KEY, ROUTER_EXPRESSION_CHANNEL_KEY, ROUTER_EXPRESSION_INCLUDE_TRANSACTION_ID, TRIGGER_ID_FILE_PARSER

Fields inherited from class org.jumpmind.symmetric.route.AbstractDataRouter

log

Constructor Summary

Constructors

Constructor and Description
TPSRouter(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	encode(byte[] byteData)
java.lang.String	getColumnNames()
ISymmetricEngine	getEngine()
java.util.Map<java.lang.Integer,java.lang.String>	getTableNames(java.lang.String tableName, java.io.File file)
java.util.List<java.lang.String>	parse(java.io.File file, int lineNumber, int tableId)
protected java.lang.String	removeIllegalCharacters(java.lang.String formattedData)

Methods inherited from class org.jumpmind.symmetric.route.AbstractFileParsingRouter

buildNodeList, createSourceFile, deleteFileIfNecessary, getRouterIdFromExternalData, getTargetTableName, getTriggerHistory, parseExternalData, readStagingFile, routeToNodes

Methods inherited from class org.jumpmind.symmetric.route.AbstractDataRouter

addNodeId, completeBatch, contextCommitted, getDataAsObject, getDataAsString, getDataMap, getDataObjectMap, getNewDataAsObject, getNewDataAsString, getNullData, getOldDataAsObject, getOldDataAsString, getPkDataAsObject, getPkDataAsString, isConfigurable, testColumnNamesMatchValues, toExternalIds, toNodeIds

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jumpmind.symmetric.route.IDataRouter

completeBatch, contextCommitted, isConfigurable, routeToNodes

Constructor Detail

TPSRouter

public TPSRouter(ISymmetricEngine engine)

Method Detail

getEngine

public ISymmetricEngine getEngine()

Specified by:

getEngine in class AbstractFileParsingRouter

parse

public java.util.List<java.lang.String> parse(java.io.File file,
                                              int lineNumber,
                                              int tableId)

Specified by:

parse in class AbstractFileParsingRouter

removeIllegalCharacters

protected java.lang.String removeIllegalCharacters(java.lang.String formattedData)

encode

protected java.lang.String encode(byte[] byteData)

getColumnNames

public java.lang.String getColumnNames()

Specified by:

getColumnNames in class AbstractFileParsingRouter

getTableNames

public java.util.Map<java.lang.Integer,java.lang.String> getTableNames(java.lang.String tableName,
                                                                       java.io.File file)
                                                                throws java.io.IOException

Overrides:

getTableNames in class AbstractFileParsingRouter

Throws:

java.io.IOException