diff options
Diffstat (limited to 'src/test/java/org/onap/aai/spike/event/incoming/OffsetManagerTest.java')
| -rw-r--r-- | src/test/java/org/onap/aai/spike/event/incoming/OffsetManagerTest.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/test/java/org/onap/aai/spike/event/incoming/OffsetManagerTest.java b/src/test/java/org/onap/aai/spike/event/incoming/OffsetManagerTest.java index 2190942..1ee106c 100644 --- a/src/test/java/org/onap/aai/spike/event/incoming/OffsetManagerTest.java +++ b/src/test/java/org/onap/aai/spike/event/incoming/OffsetManagerTest.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -33,10 +33,10 @@ public class OffsetManagerTest { @Test public void testOffsetAdvancement() throws Exception { - final Long offsetPeriod = 500L; // ms + final Long offsetPeriod = 100L; // ms // Create an instance of the offset manager. - OffsetManager offsetManager = new OffsetManager(10, offsetPeriod); + OffsetManager offsetManager = new OffsetManager(5, offsetPeriod); // Now, cache some events as if we had consumed them and they // are in flight. |