From fb342679551d31bd687b6eb7ec48231e23185817 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Paw=20Figg=C3=A9=20Kjeldgaard?= Date: Sat, 6 Jan 2024 16:13:59 +0100 Subject: [PATCH] Updated dependencies and fixed formatting --- .github/project.yml | 4 ++-- docs/modules/ROOT/pages/includes/attributes.adoc | 2 +- pom.xml | 10 +++++----- .../nats/jetstream/JetStreamBuildConfiguration.java | 4 ++-- .../nats/jetstream/setup/JetStreamSetup.java | 12 ++++++------ 5 files changed, 16 insertions(+), 16 deletions(-) diff --git a/.github/project.yml b/.github/project.yml index 494c229a..0074cc50 100644 --- a/.github/project.yml +++ b/.github/project.yml @@ -1,4 +1,4 @@ release: - current-version: "0" - next-version: "999-SNAPSHOT" + current-version: "1.0.0" + next-version: "1.1.0-SNAPSHOT" diff --git a/docs/modules/ROOT/pages/includes/attributes.adoc b/docs/modules/ROOT/pages/includes/attributes.adoc index 19a687e2..8731c868 100644 --- a/docs/modules/ROOT/pages/includes/attributes.adoc +++ b/docs/modules/ROOT/pages/includes/attributes.adoc @@ -1,3 +1,3 @@ -:project-version: 0 +:project-version: 1.0.0 :examples-dir: ./../examples/ \ No newline at end of file diff --git a/pom.xml b/pom.xml index 4decbb3f..542cc5a2 100644 --- a/pom.xml +++ b/pom.xml @@ -23,18 +23,18 @@ https://github.com/quarkiverse/quarkus-reactive-messsaging-nats-jetstream - 3.11.0 + 3.12.1 11 UTF-8 UTF-8 3.6.4 - 2.17.1 + 2.17.2 0.3.0 - 4.13.0 - 4.13.0 + 4.15.0 + 4.15.0 3.1 - 3.24.2 + 3.25.1 diff --git a/runtime/src/main/java/io/quarkiverse/reactive/messsaging/nats/jetstream/JetStreamBuildConfiguration.java b/runtime/src/main/java/io/quarkiverse/reactive/messsaging/nats/jetstream/JetStreamBuildConfiguration.java index f288cf33..a18af43e 100644 --- a/runtime/src/main/java/io/quarkiverse/reactive/messsaging/nats/jetstream/JetStreamBuildConfiguration.java +++ b/runtime/src/main/java/io/quarkiverse/reactive/messsaging/nats/jetstream/JetStreamBuildConfiguration.java @@ -27,9 +27,9 @@ public interface JetStreamBuildConfiguration { @WithDefault("File") String storageType(); - /** - * Declares the retention policy for the stream. @see Retention Policy + * Declares the retention policy for the stream. @see + * Retention Policy */ @WithDefault("Interest") String retentionPolicy(); diff --git a/runtime/src/main/java/io/quarkiverse/reactive/messsaging/nats/jetstream/setup/JetStreamSetup.java b/runtime/src/main/java/io/quarkiverse/reactive/messsaging/nats/jetstream/setup/JetStreamSetup.java index 3079a230..ff2fc57e 100644 --- a/runtime/src/main/java/io/quarkiverse/reactive/messsaging/nats/jetstream/setup/JetStreamSetup.java +++ b/runtime/src/main/java/io/quarkiverse/reactive/messsaging/nats/jetstream/setup/JetStreamSetup.java @@ -20,7 +20,7 @@ public class JetStreamSetup { private static final Logger logger = Logger.getLogger(JetStreamSetup.class); public void setup(Connection connection, - JetStreamBuildConfiguration jetStreamConfiguration) { + JetStreamBuildConfiguration jetStreamConfiguration) { try { final var jsm = connection.jetStreamManagement(); getStreams() @@ -52,8 +52,8 @@ private Optional getStreamInfo(JetStreamManagement jsm, String strea } private void createStreamConfiguration(JetStreamManagement jsm, - Stream stream, - JetStreamBuildConfiguration jetStreamConfiguration) { + Stream stream, + JetStreamBuildConfiguration jetStreamConfiguration) { try { logger.infof("Creating stream: %s with subjects: %s", stream.name(), stream.subjects()); StreamConfiguration.Builder streamConfigBuilder = StreamConfiguration.builder() @@ -70,9 +70,9 @@ private void createStreamConfiguration(JetStreamManagement jsm, } private void updateStreamConfiguration(JetStreamManagement jsm, - StreamConfiguration streamConfiguration, - Stream stream, - JetStreamBuildConfiguration jetStreamConfiguration) { + StreamConfiguration streamConfiguration, + Stream stream, + JetStreamBuildConfiguration jetStreamConfiguration) { try { if (!new HashSet<>(streamConfiguration.getSubjects()).containsAll(stream.subjects())) { logger.infof("Updating stream %s with subjects %s", streamConfiguration.getName(), stream.subjects());