Skip to content

Commit

Permalink
Merge pull request #9 from quarkiverse/feature/update-dependencies
Browse files Browse the repository at this point in the history
Updated dependencies and fixed formatting
  • Loading branch information
kjeldpaw authored Jan 9, 2024
2 parents 8807c43 + fb34267 commit 6ce861b
Show file tree
Hide file tree
Showing 5 changed files with 16 additions and 16 deletions.
4 changes: 2 additions & 2 deletions .github/project.yml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
release:
current-version: "0"
next-version: "999-SNAPSHOT"
current-version: "1.0.0"
next-version: "1.1.0-SNAPSHOT"

2 changes: 1 addition & 1 deletion docs/modules/ROOT/pages/includes/attributes.adoc
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
:project-version: 0
:project-version: 1.0.0

:examples-dir: ./../examples/
10 changes: 5 additions & 5 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -23,18 +23,18 @@
<url>https://github.com/quarkiverse/quarkus-reactive-messsaging-nats-jetstream</url>
</scm>
<properties>
<compiler-plugin.version>3.11.0</compiler-plugin.version>
<compiler-plugin.version>3.12.1</compiler-plugin.version>
<maven.compiler.release>11</maven.compiler.release>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<quarkus.version>3.6.4</quarkus.version>

<jnats.version>2.17.1</jnats.version>
<jnats.version>2.17.2</jnats.version>
<eddsa.version>0.3.0</eddsa.version>
<smallrye-connector-attribute-processor.version>4.13.0</smallrye-connector-attribute-processor.version>
<smallrye-reactive-messaging-otel.version>4.13.0</smallrye-reactive-messaging-otel.version>
<smallrye-connector-attribute-processor.version>4.15.0</smallrye-connector-attribute-processor.version>
<smallrye-reactive-messaging-otel.version>4.15.0</smallrye-reactive-messaging-otel.version>
<microprofile-config-api.version>3.1</microprofile-config-api.version>
<assertj-core.version>3.24.2</assertj-core.version>
<assertj-core.version>3.25.1</assertj-core.version>
</properties>
<dependencyManagement>
<dependencies>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,9 +27,9 @@ public interface JetStreamBuildConfiguration {
@WithDefault("File")
String storageType();


/**
* Declares the retention policy for the stream. @see <a href="https://docs.nats.io/jetstream/concepts/streams#retention-policies">Retention Policy</a>
* Declares the retention policy for the stream. @see
* <a href="https://docs.nats.io/jetstream/concepts/streams#retention-policies">Retention Policy</a>
*/
@WithDefault("Interest")
String retentionPolicy();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down Expand Up @@ -52,8 +52,8 @@ private Optional<StreamInfo> 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()
Expand All @@ -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());
Expand Down

0 comments on commit 6ce861b

Please sign in to comment.