aboutsummaryrefslogtreecommitdiffstats
path: root/src/test/java/org/onap/aai/spike/event/incoming/OffsetManagerTest.java
diff options
context:
space:
mode:
authorMichael Arrastia <MArrasti@amdocs.com>2018-12-17 17:34:37 +0000
committerMichael Arrastia <MArrasti@amdocs.com>2018-12-17 18:27:04 +0000
commit69d4c0a747053473355ee82aa426589324e50d82 (patch)
tree735d591809d861326ee7e3ec93ad8a49bd0d101e /src/test/java/org/onap/aai/spike/event/incoming/OffsetManagerTest.java
parent9a6079fe14815e6f247268ce32b3157cf95d734b (diff)
Use Schema Service for model ingestion
Change-Id: Id2531c52491c135ae000223caf7ce79f95a9cb43 Issue-ID: AAI-2010 Signed-off-by: Michael Arrastia <MArrasti@amdocs.com>
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.java6
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.