diff --git a/chronicle-queue/pom.xml b/chronicle-queue/pom.xml index 39cf752492..a91f71736a 100755 --- a/chronicle-queue/pom.xml +++ b/chronicle-queue/pom.xml @@ -49,7 +49,7 @@ net.openhft chronicle-bom - 1.10.43-SNAPSHOT + 1.10.43 pom import diff --git a/chronicle-queue/src/test/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueueTest.java b/chronicle-queue/src/test/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueueTest.java index 03d4bb46ca..32c4670ea8 100755 --- a/chronicle-queue/src/test/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueueTest.java +++ b/chronicle-queue/src/test/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueueTest.java @@ -179,7 +179,7 @@ public void testAppendAndReadWithRolling() throws IOException { } } - @Ignore("todo - rob to fix") + @Test public void testAppendAndReadWithRolling2() throws IOException { final File dir = getTmpDir(); @@ -449,4 +449,27 @@ public void testIndex() throws Exception { } + @Test + public void testEPOC() throws Exception { + + File file = File.createTempFile("chronicle.", "q"); + file.deleteOnExit(); + try { + + final ChronicleQueue chronicle = new SingleChronicleQueueBuilder(getTmpDir()) + .wireType(this.wireType) + .epoc(System.currentTimeMillis()) + .rollCycle(RollCycles.HOURS) + .build(); + + final ExcerptAppender appender = chronicle.createAppender(); + appender.writeDocument(wire -> wire.write(() -> "key").text("value=v")); + Assert.assertEquals(0, appender.cycle()); + + } finally { + file.delete(); + } + } + + }