Package org.jumpmind.symmetric.service.impl

Class AbstractRouterServiceTest

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractServiceTest

org.jumpmind.symmetric.service.impl.AbstractRouterServiceTest

Direct Known Subclasses:

JdbcRouterServiceTest

public abstract class AbstractRouterServiceTest
extends AbstractServiceTest

Field Summary

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractServiceTest

engine

Constructor Summary

Constructors

Constructor	Description
AbstractRouterServiceTest()

Method Summary

Modifier and Type	Method	Description
protected int	countBatchesForChannel(OutgoingBatches batches, NodeChannel channel)
protected int	countUnroutedBatches()
protected void	deleteAll(String tableName)
protected void	execute(String sql, String node2disable)
protected void	filterForChannels(OutgoingBatches batches, NodeChannel... channels)
protected TriggerRouter	getTestRoutingTableTrigger(String tableName)
protected void	insert(String tableName, int count, boolean transactional)
protected void	insert(String tableName, int count, boolean transactional, String node2disable)
protected void	insert(String tableName, int count, boolean transactional, String node2disable, String routingVarcharFieldValue)
protected void	insert(String tableName, int count, boolean transactional, String node2disable, String routingVarcharFieldValue, boolean rollback)
protected void	insertGaps(int insertedCount, int rollbackCount, int repeatCount)
protected void	setUpDefaultTriggerRouterForTable1()
void	testBshRoutingDeletesToNode3()
void	testBshTransactionalRoutingOnUpdate()
void	testColumnMatchOnNotNull()
void	testColumnMatchOnNull()
void	testColumnMatchSubtableRoutingToNode1()
void	testColumnMatchTransactionalOnlyRoutingToNode1()
void	testDataGapExpired()
void	testDefaultRouteToTargetNodeGroupOnly()
void	testDontSelectOldDataDuringRouting()
void	testGapRouting()
void	testGapWithGapAtBegining()
void	testGapWithGapAtEnd()
void	testLargeNumberOfEventsToManyNodes()
void	testLookupTableRouting()
void	testLotsOfGaps()
void	testMaxNumberOfDataToRoute()
void	testMultiChannelRoutingToEveryone()
void	testNoResend()
void	testRoutingScenarios()
void	testSubSelectNonTransactionalRoutingToNode1()
void	testSyncIncomingBatch()
void	testSyncIncomingBatchWhenUnrouted()
void	testSyncOnColumnChange()
void	testUnroutedDataCreatedBatch()
protected void	update(String tableName, String value)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractServiceTest

assertEquals, assertEquals, assertFalse, assertFalse, assertNotNull, assertNotNull, assertNotSame, assertNull, assertNull, assertNumberOfLinesThatStartWith, assertNumberOfLinesThatStartWith, assertNumberOfRows, assertTrue, assertTrue, checkForOpenResources, countData, forceRebuildOfTrigers, formatTableName, getClusterService, getConfigurationService, getDataExtractorService, getDataService, getDbDialect, getIncomingBatchService, getNodeService, getOutgoingBatchService, getParameterService, getPlatform, getRegistrationService, getRouterService, getSqlTemplate, getStagingManager, getSymmetricEngine, getTriggerRouterService, logTestComplete, logTestRunning, printDatabase, resetBatches, resetGaps, routeAndCreateGaps, setLoggingLevelForTest, setup

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractRouterServiceTest

public AbstractRouterServiceTest()

Method Details

testRoutingScenarios

@Test
public void testRoutingScenarios()
                          throws Exception

Throws:

Exception

testMultiChannelRoutingToEveryone

public void testMultiChannelRoutingToEveryone()

testLookupTableRouting

public void testLookupTableRouting()

testColumnMatchTransactionalOnlyRoutingToNode1

public void testColumnMatchTransactionalOnlyRoutingToNode1()

testSubSelectNonTransactionalRoutingToNode1

public void testSubSelectNonTransactionalRoutingToNode1()

testSyncIncomingBatch

public void testSyncIncomingBatch()
                           throws Exception

Throws:

Exception

testLargeNumberOfEventsToManyNodes

public void testLargeNumberOfEventsToManyNodes()

testBshTransactionalRoutingOnUpdate

public void testBshTransactionalRoutingOnUpdate()

testBshRoutingDeletesToNode3

public void testBshRoutingDeletesToNode3()

testColumnMatchSubtableRoutingToNode1

public void testColumnMatchSubtableRoutingToNode1()

testColumnMatchOnNull

public void testColumnMatchOnNull()

testColumnMatchOnNotNull

public void testColumnMatchOnNotNull()

testSyncOnColumnChange

public void testSyncOnColumnChange()

testSyncIncomingBatchWhenUnrouted

public void testSyncIncomingBatchWhenUnrouted()
                                       throws Exception

Throws:

Exception

testDefaultRouteToTargetNodeGroupOnly

public void testDefaultRouteToTargetNodeGroupOnly()
                                           throws Exception

Throws:

Exception

testUnroutedDataCreatedBatch

public void testUnroutedDataCreatedBatch()

testGapRouting

public void testGapRouting()
                    throws Exception

Throws:

Exception

testGapWithGapAtBegining

public void testGapWithGapAtBegining()

testGapWithGapAtEnd

public void testGapWithGapAtEnd()

testDataGapExpired

public void testDataGapExpired()
                        throws Exception

Throws:

Exception

testLotsOfGaps

public void testLotsOfGaps()

testNoResend

public void testNoResend()

testDontSelectOldDataDuringRouting

public void testDontSelectOldDataDuringRouting()
                                        throws Exception

Throws:

Exception

testMaxNumberOfDataToRoute

public void testMaxNumberOfDataToRoute()

setUpDefaultTriggerRouterForTable1

protected void setUpDefaultTriggerRouterForTable1()

countUnroutedBatches

protected int countUnroutedBatches()

getTestRoutingTableTrigger

protected TriggerRouter getTestRoutingTableTrigger(String tableName)

filterForChannels

protected void filterForChannels(OutgoingBatches batches,
 NodeChannel... channels)

countBatchesForChannel

protected int countBatchesForChannel(OutgoingBatches batches,
 NodeChannel channel)

insertGaps

protected void insertGaps(int insertedCount,
 int rollbackCount,
 int repeatCount)

deleteAll

protected void deleteAll(String tableName)

insert

protected void insert(String tableName,
 int count,
 boolean transactional)

insert

protected void insert(String tableName,
 int count,
 boolean transactional,
 String node2disable)

insert

protected void insert(String tableName,
 int count,
 boolean transactional,
 String node2disable,
 String routingVarcharFieldValue)

insert

protected void insert(String tableName,
 int count,
 boolean transactional,
 String node2disable,
 String routingVarcharFieldValue,
 boolean rollback)

update

protected void update(String tableName,
 String value)

execute

protected void execute(String sql,
 String node2disable)