diff --git a/CHANGELOG.md b/CHANGELOG.md index 6bb0ded..c04d020 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -13,6 +13,12 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0. - Add batch write/read (using FileChannel) with customizable batch size; - Add concurrent access to queue (methods with `synchronized` keyword or based on locks). +## [2.0.2](https://github.com/infobip/popout/releases/tag/2.0.2) - 2019-04-19 + +### Changed + +- Refactored dependencies management. + ## [2.0.1](https://github.com/infobip/popout/releases/tag/2.0.1) - 2019-04-17 ### Added diff --git a/README.md b/README.md index fccb2de..984bb90 100644 --- a/README.md +++ b/README.md @@ -46,7 +46,7 @@ Include the dependency to your project's pom.xml file: org.infobip.lib popout - 2.0.1 + 2.0.2 ... @@ -55,7 +55,7 @@ Include the dependency to your project's pom.xml file: or Gradle: ```groovy -compile 'org.infobip.lib:poput:2.0.1' +compile 'org.infobip.lib:poput:2.0.2' ``` ### Create a queue diff --git a/benchmarks/pom.xml b/benchmarks/pom.xml index dcc8aee..6684768 100644 --- a/benchmarks/pom.xml +++ b/benchmarks/pom.xml @@ -25,7 +25,7 @@ limitations under the License. org.infobip.lib parent - 2.0.1 + 2.0.2 benchmarks @@ -33,17 +33,11 @@ limitations under the License. [popout]: Benchmark tests - - io.appulse - logging-java - 1.1.1 - ${project.groupId} popout - 2.0.1 + ${project.version} - com.squareup.tape2 tape @@ -55,13 +49,18 @@ limitations under the License. jmh-core 1.21 - org.openjdk.jmh jmh-generator-annprocess 1.21 provided + + + org.projectlombok + lombok + provided + diff --git a/benchmarks/src/main/java/org/infobip/lib/popout/benchmarks/Main.java b/benchmarks/src/main/java/org/infobip/lib/popout/benchmarks/Main.java deleted file mode 100644 index 14aebe9..0000000 --- a/benchmarks/src/main/java/org/infobip/lib/popout/benchmarks/Main.java +++ /dev/null @@ -1,90 +0,0 @@ -package org.infobip.lib.popout.benchmarks; - -import static io.appulse.utils.SizeUnit.MEGABYTES; -import static java.util.Comparator.reverseOrder; - -import java.io.File; -import java.nio.file.Files; -import java.nio.file.Path; -import java.nio.file.Paths; -import java.util.concurrent.ThreadLocalRandom; - -import org.infobip.lib.popout.CompressedFilesConfig; -import org.infobip.lib.popout.Deserializer; -import org.infobip.lib.popout.FileQueue; -import org.infobip.lib.popout.QueueLimit; -import org.infobip.lib.popout.Serializer; -import org.infobip.lib.popout.WalFilesConfig; -import org.infobip.lib.popout.batched.BatchedFileQueueBuilder; - -import lombok.SneakyThrows; -import lombok.val; -import lombok.extern.slf4j.Slf4j; - -@Slf4j -public class Main { - - private static final Path TEST_FILES = Paths.get("./tests_files"); - - public static void main (String[] args) throws Exception { - deleteFolder(TEST_FILES); - Files.createDirectories(TEST_FILES); - - byte[] payload = new byte[512]; - ThreadLocalRandom.current().nextBytes(payload); - val builder = queueBuilder(); - - try (val queue = builder.build()) { - log.info("Creating temporary files for READ benchmark tests"); - for (int i = 0; i < 25_000_000; i++) { - queue.add(payload); - } - log.info("Creating files end"); - - log.info("Start polling"); - do { - try { - val item = queue.poll(); - if (item == null) { - break; - } - } catch (Throwable ex) { - log.error("ERROR", ex); - System.exit(1); - } - } while (true); - log.info("End polling"); - } - } - - private static BatchedFileQueueBuilder queueBuilder () { - return FileQueue.batched() - .name("my-test") - .folder(TEST_FILES) - .serializer(Serializer.BYTE_ARRAY) - .deserializer(Deserializer.BYTE_ARRAY) - .limit(QueueLimit.noLimit()) - .restoreFromDisk(false) - .wal(WalFilesConfig.builder() - .folder(TEST_FILES) - .maxCount(1000) - .build()) - .compressed(CompressedFilesConfig.builder() - .folder(TEST_FILES) - .maxSizeBytes(MEGABYTES.toBytes(256)) - .build()) - .batchSize(10_000); - } - - @SneakyThrows - private static void deleteFolder (Path path) { - if (Files.notExists(path)) { - return; - } - - Files.walk(path) - .sorted(reverseOrder()) - .map(Path::toFile) - .forEach(File::delete); - } -} diff --git a/pom.xml b/pom.xml index 32bba73..c32e513 100644 --- a/pom.xml +++ b/pom.xml @@ -24,7 +24,7 @@ limitations under the License. org.infobip.lib parent - 2.0.1 + 2.0.2 pom @@ -71,7 +71,7 @@ limitations under the License. https://github.com/infobip/popout scm:git:https://github.com/infobip/popout.git scm:git:https://github.com/infobip/popout.git - 2.0.1 + 2.0.2 @@ -103,66 +103,65 @@ limitations under the License. - - - org.projectlombok - lombok - 1.18.6 - provided - - - - org.junit.jupiter - junit-jupiter-engine - 5.4.1 - test - - - org.junit.jupiter - junit-jupiter-params - 5.4.1 - test - - - - org.assertj - assertj-core - 3.12.2 - test - - - - org.mockito - mockito-core - 2.25.1 - test - - - org.mockito - mockito-junit-jupiter - 2.25.1 - test - - - - net.jcip - jcip-annotations - 1.0 - provided - - - com.github.spotbugs - spotbugs-annotations - 3.1.12 - provided - - - com.google.code.findbugs - jsr305 - 3.0.2 - provided - - + + + + io.appulse + utils-java + 1.15.0 + + + + org.projectlombok + lombok + 1.18.6 + + + + org.junit.jupiter + junit-jupiter-engine + 5.4.1 + + + org.junit.jupiter + junit-jupiter-params + 5.4.1 + + + + org.assertj + assertj-core + 3.12.2 + + + + org.mockito + mockito-core + 2.25.1 + + + org.mockito + mockito-junit-jupiter + 2.25.1 + + + + net.jcip + jcip-annotations + 1.0 + + + com.github.spotbugs + spotbugs-annotations + 3.1.12 + + + com.google.code.findbugs + jsr305 + 3.0.2 + + + diff --git a/popout/pom.xml b/popout/pom.xml index 59f0101..8b07e57 100644 --- a/popout/pom.xml +++ b/popout/pom.xml @@ -25,7 +25,7 @@ limitations under the License. org.infobip.lib parent - 2.0.1 + 2.0.2 popout @@ -36,7 +36,56 @@ limitations under the License. io.appulse utils-java - 1.15.0 + + + + org.projectlombok + lombok + provided + + + + org.junit.jupiter + junit-jupiter-engine + test + + + org.junit.jupiter + junit-jupiter-params + test + + + + org.assertj + assertj-core + test + + + + org.mockito + mockito-core + test + + + org.mockito + mockito-junit-jupiter + test + + + + net.jcip + jcip-annotations + provided + + + com.github.spotbugs + spotbugs-annotations + provided + + + com.google.code.findbugs + jsr305 + provided