Package 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:

IBuiltInExtensionPoint, IExtensionPoint, IDataRouter

public class TPSRouter
extends AbstractFileParsingRouter
implements IDataRouter, 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	Description
TPSRouter(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
protected String	encode(byte[] byteData)
String	getColumnNames()
ISymmetricEngine	getEngine()
Map<Integer,String>	getTableNames(String tableName, File file)
List<String>	parse(File file, int lineNumber, int tableId)
protected String	removeIllegalCharacters(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, isDmlOnly, 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, isDmlOnly, routeToNodes

Constructor Details

TPSRouter

public TPSRouter(ISymmetricEngine engine)

Method Details

getEngine

public ISymmetricEngine getEngine()

Specified by:

getEngine in class AbstractFileParsingRouter

parse

public List<String> parse(File file,
 int lineNumber,
 int tableId)

Specified by:

parse in class AbstractFileParsingRouter

removeIllegalCharacters

protected String removeIllegalCharacters(String formattedData)

encode

protected String encode(byte[] byteData)

getColumnNames

public String getColumnNames()

Specified by:

getColumnNames in class AbstractFileParsingRouter

getTableNames

public Map<Integer,String> getTableNames(String tableName,
 File file)
                                  throws IOException

Overrides:

getTableNames in class AbstractFileParsingRouter

Throws:

IOException