From 7b8b814276552d42066bdc4d27562f897defdf21 Mon Sep 17 00:00:00 2001 From: Her Date: Fri, 7 Sep 2018 10:18:08 +0200 Subject: [PATCH] Fix for runtime errors when bounded is compiled with a version higher that Java 8 and used in a Java 8 project. --- .../eventmaterializers/offsetstores/LmdbOffsetStore.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/bounded-core/src/main/scala/io/cafienne/bounded/eventmaterializers/offsetstores/LmdbOffsetStore.scala b/bounded-core/src/main/scala/io/cafienne/bounded/eventmaterializers/offsetstores/LmdbOffsetStore.scala index 19ba7f3..9b9e68c 100644 --- a/bounded-core/src/main/scala/io/cafienne/bounded/eventmaterializers/offsetstores/LmdbOffsetStore.scala +++ b/bounded-core/src/main/scala/io/cafienne/bounded/eventmaterializers/offsetstores/LmdbOffsetStore.scala @@ -5,7 +5,7 @@ package io.cafienne.bounded.eventmaterializers.offsetstores import java.io.File -import java.nio.ByteBuffer +import java.nio.{Buffer, ByteBuffer} import java.nio.ByteBuffer.allocateDirect import java.nio.charset.StandardCharsets.UTF_8 import java.util.UUID @@ -33,10 +33,10 @@ private class LmdbOffsetStore(lmdbConfig: LmdbConfig) extends OffsetStore { val txn = env.txnWrite() try { val keyByteBuffer = allocateDirect(100) - keyByteBuffer.put(viewIdentifier.getBytes(UTF_8)).flip + keyByteBuffer.put(viewIdentifier.getBytes(UTF_8)).asInstanceOf[Buffer].flip val valueByteBuffer = allocateDirect(300) - valueByteBuffer.put(offset2String(offset).getBytes(UTF_8)).flip() + valueByteBuffer.put(offset2String(offset).getBytes(UTF_8)).asInstanceOf[Buffer].flip() dbi.put(txn, keyByteBuffer, valueByteBuffer) txn.commit() } finally { @@ -49,7 +49,7 @@ private class LmdbOffsetStore(lmdbConfig: LmdbConfig) extends OffsetStore { val txn = env.txnRead() try { val keyByteBuffer = allocateDirect(100) - keyByteBuffer.put(viewIdentifier.getBytes(UTF_8)).flip + keyByteBuffer.put(viewIdentifier.getBytes(UTF_8)).asInstanceOf[Buffer].flip val found = dbi.get(txn, keyByteBuffer) if (found != null) { val fetchedVal = txn.`val`()