Skip to content

Commit

Permalink
SYMMETRICDS-577
Browse files Browse the repository at this point in the history
  • Loading branch information
chenson42 committed Jan 31, 2012
1 parent 2de021f commit 249c66a
Showing 1 changed file with 4 additions and 1 deletion.
Expand Up @@ -30,7 +30,7 @@
import org.junit.Assert;
import org.junit.Test;

public class OutgoingBatchesUnitTest {
public class OutgoingBatchesTest {

public static final String[] nodeIds = { "0001", "0002", "0003", "0004", "0005" };

Expand Down Expand Up @@ -187,6 +187,7 @@ public void testChannelSortingOneErrors() {
List<OutgoingBatch> batches = new ArrayList<OutgoingBatch>();
OutgoingBatch batch1 = new OutgoingBatch("1", channelA.getChannelId(), Status.NE);
batch1.setStatus(OutgoingBatch.Status.ER);
batch1.setErrorFlag(true);
batches.add(batch1);

OutgoingBatch batch2 = new OutgoingBatch("1", channelB.getChannelId(), Status.NE);
Expand Down Expand Up @@ -223,13 +224,15 @@ public void testChannelSortingTwoErrors() {
List<OutgoingBatch> batches = new ArrayList<OutgoingBatch>();
OutgoingBatch batch1 = new OutgoingBatch("1", channelA.getChannelId(), Status.NE);
batch1.setStatus(OutgoingBatch.Status.ER);
batch1.setErrorFlag(true);
batch1.setLastUpdatedTime(new Date());
batches.add(batch1);

AppUtils.sleep(50);

OutgoingBatch batch2 = new OutgoingBatch("1", channelB.getChannelId(), Status.NE);
batch2.setStatus(OutgoingBatch.Status.ER);
batch2.setErrorFlag(true);
batch2.setLastUpdatedTime(new Date());
batches.add(batch2);

Expand Down

0 comments on commit 249c66a

Please sign in to comment.