Package org.jumpmind.symmetric.service.impl

Class PurgeServiceTest

java.lang.Object

org.jumpmind.symmetric.service.impl.PurgeServiceTest

public class PurgeServiceTest
extends Object

Constructor Summary

Constructors

Constructor	Description
PurgeServiceTest()

Method Summary

Modifier and Type	Method	Description
protected org.jumpmind.symmetric.service.impl.PurgeServiceTest.TestContext	getTestContext(List<Data> datas, List<DataEvent> dataEvents, List<OutgoingBatch> batches)
protected List<Data>	newDataList(int... ids)
protected OutgoingBatch	newOutgoingBatch(long batchId, String channelId, AbstractBatch.Status status, boolean isOld)
protected void	populateContextData(org.jumpmind.symmetric.service.impl.PurgeServiceTest.TestContext context, List<Data> datas)
protected void	populateContextDataEvent(org.jumpmind.symmetric.service.impl.PurgeServiceTest.TestContext context, List<DataEvent> dataEvents)
protected void	populateContextOutgoingBatch(org.jumpmind.symmetric.service.impl.PurgeServiceTest.TestContext context, List<OutgoingBatch> batches)
void	setUp()
protected void	setupWhen(List<Data> datas, List<DataEvent> dataEvents, List<OutgoingBatch> batches, long minGapStartId)
void	testPurgeAroundSmallGaps()
void	testPurgeDelayedChannel()
void	testPurgeDelayedChannelAgain()
void	testPurgeGapFilledAfterPurgeWindow()
void	testPurgeNewBatchOldDataOneChannel()
void	testPurgeNewBatchOldDataTwoChannels()
protected void	verifyPurgeContext(long lastDataId, long lastEventBatchId, long lastBatchId)
protected void	verifyPurgeData(long startRangeId, long endRangeId, long startExistsId, long endExistsId)
protected void	verifyPurgeDataEvent(long startRangeId, long endRangeId, long startExistsId, long endExistsId)
protected void	verifyPurgeOutgoingBatch(long startRangeId, long endRangeId, long startExistsId, long endExistsId)

Methods inherited from class java.lang.Object

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

Constructor Details

PurgeServiceTest

public PurgeServiceTest()

Method Details

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

testPurgeDelayedChannel

@Test
public void testPurgeDelayedChannel()

testPurgeDelayedChannelAgain

@Test
public void testPurgeDelayedChannelAgain()

testPurgeNewBatchOldDataTwoChannels

@Test
public void testPurgeNewBatchOldDataTwoChannels()

testPurgeNewBatchOldDataOneChannel

@Test
public void testPurgeNewBatchOldDataOneChannel()

testPurgeGapFilledAfterPurgeWindow

@Test
public void testPurgeGapFilledAfterPurgeWindow()

testPurgeAroundSmallGaps

@Test
public void testPurgeAroundSmallGaps()

newDataList

protected List<Data> newDataList(int... ids)

newOutgoingBatch

protected OutgoingBatch newOutgoingBatch(long batchId,
 String channelId,
 AbstractBatch.Status status,
 boolean isOld)

setupWhen

protected void setupWhen(List<Data> datas,
 List<DataEvent> dataEvents,
 List<OutgoingBatch> batches,
 long minGapStartId)

getTestContext

protected org.jumpmind.symmetric.service.impl.PurgeServiceTest.TestContext getTestContext(List<Data> datas,
 List<DataEvent> dataEvents,
 List<OutgoingBatch> batches)

populateContextData

protected void populateContextData(org.jumpmind.symmetric.service.impl.PurgeServiceTest.TestContext context,
 List<Data> datas)

populateContextOutgoingBatch

protected void populateContextOutgoingBatch(org.jumpmind.symmetric.service.impl.PurgeServiceTest.TestContext context,
 List<OutgoingBatch> batches)

populateContextDataEvent

protected void populateContextDataEvent(org.jumpmind.symmetric.service.impl.PurgeServiceTest.TestContext context,
 List<DataEvent> dataEvents)

verifyPurgeData

protected void verifyPurgeData(long startRangeId,
 long endRangeId,
 long startExistsId,
 long endExistsId)

verifyPurgeDataEvent

protected void verifyPurgeDataEvent(long startRangeId,
 long endRangeId,
 long startExistsId,
 long endExistsId)

verifyPurgeOutgoingBatch

protected void verifyPurgeOutgoingBatch(long startRangeId,
 long endRangeId,
 long startExistsId,
 long endExistsId)

verifyPurgeContext

protected void verifyPurgeContext(long lastDataId,
 long lastEventBatchId,
 long lastBatchId)