Skip to content

Commit

Permalink
Bump quarkus.version from 2.16.6.Final to 3.0.0.Final (#155)
Browse files Browse the repository at this point in the history
Closes #156 too.
  • Loading branch information
michael-simons committed Apr 17, 2023
1 parent 252d794 commit 80ed981
Show file tree
Hide file tree
Showing 13 changed files with 54 additions and 60 deletions.
2 changes: 1 addition & 1 deletion .github/project.yml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
release:
current-version: 2.2.7
next-version: 2.2.8-SNAPSHOT
next-version: 3.0.0-SNAPSHOT

2 changes: 1 addition & 1 deletion deployment/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
<parent>
<groupId>io.quarkiverse.neo4j</groupId>
<artifactId>quarkus-neo4j-parent</artifactId>
<version>2.2.8-SNAPSHOT</version>
<version>3.0.0-SNAPSHOT</version>
</parent>
<artifactId>quarkus-neo4j-deployment</artifactId>
<name>Quarkus - Neo4j - Deployment</name>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
import java.util.function.Predicate;
import java.util.logging.LogRecord;

import javax.inject.Inject;
import jakarta.inject.Inject;

import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.Test;
Expand Down
2 changes: 1 addition & 1 deletion docs/modules/ROOT/pages/includes/attributes.adoc
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
:quarkus-version: 2.16.6.Final
:quarkus-version: 3.0.0.Final
:quarkus-neo4j-version: 2.2.7
:maven-version: 3.8.1+

Expand Down
2 changes: 1 addition & 1 deletion docs/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
<parent>
<groupId>io.quarkiverse.neo4j</groupId>
<artifactId>quarkus-neo4j-parent</artifactId>
<version>2.2.8-SNAPSHOT</version>
<version>3.0.0-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion integration-tests/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
<parent>
<groupId>io.quarkiverse.neo4j</groupId>
<artifactId>quarkus-neo4j-parent</artifactId>
<version>2.2.8-SNAPSHOT</version>
<version>3.0.0-SNAPSHOT</version>
</parent>
<artifactId>quarkus-neo4j-integration-tests</artifactId>
<name>Quarkus - Neo4j - Integration Tests</name>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,17 +7,17 @@
import java.util.concurrent.CompletionException;
import java.util.concurrent.CompletionStage;

import javax.inject.Inject;
import javax.ws.rs.Consumes;
import javax.ws.rs.DELETE;
import javax.ws.rs.GET;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import javax.ws.rs.core.Response.ResponseBuilder;
import javax.ws.rs.core.Response.Status;
import jakarta.inject.Inject;
import jakarta.ws.rs.Consumes;
import jakarta.ws.rs.DELETE;
import jakarta.ws.rs.GET;
import jakarta.ws.rs.POST;
import jakarta.ws.rs.Path;
import jakarta.ws.rs.Produces;
import jakarta.ws.rs.core.MediaType;
import jakarta.ws.rs.core.Response;
import jakarta.ws.rs.core.Response.ResponseBuilder;
import jakarta.ws.rs.core.Response.Status;

import org.eclipse.microprofile.context.ThreadContext;
import org.neo4j.driver.Driver;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,18 +1,17 @@
package io.quarkus.it.neo4j;

import static javax.ws.rs.core.MediaType.*;
import static org.reactivestreams.FlowAdapters.toFlowPublisher;
import static org.reactivestreams.FlowAdapters.toPublisher;
import static jakarta.ws.rs.core.MediaType.*;

import java.io.PrintWriter;
import java.io.StringWriter;
import java.util.List;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.Flow;

import javax.inject.Inject;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import jakarta.inject.Inject;
import jakarta.ws.rs.GET;
import jakarta.ws.rs.Path;
import jakarta.ws.rs.Produces;

import org.eclipse.microprofile.context.ThreadContext;
import org.neo4j.driver.Driver;
Expand All @@ -21,8 +20,8 @@
import org.neo4j.driver.Transaction;
import org.neo4j.driver.Values;
import org.neo4j.driver.async.AsyncSession;
import org.neo4j.driver.reactive.ReactiveResult;
import org.neo4j.driver.reactive.ReactiveSession;
import org.reactivestreams.Publisher;

import io.smallrye.mutiny.Multi;
import io.smallrye.mutiny.Uni;
Expand Down Expand Up @@ -76,18 +75,17 @@ public CompletionStage<List<Integer>> doStuffWithNeo4jAsynchronous() {
@GET
@Path("/reactive")
@Produces(SERVER_SENT_EVENTS)
public Publisher<Integer> doStuffWithNeo4jReactive() {
public Flow.Publisher<Integer> doStuffWithNeo4jReactive() {

return Multi.createFrom().resource(() -> driver.session(ReactiveSession.class),
session -> toPublisher(session.executeRead(tx -> {
session -> session.executeRead(tx -> {
var result = tx.run("UNWIND range(1, 3) AS x RETURN x");
return toFlowPublisher(
Multi.createFrom().publisher(toPublisher(result))
.flatMap(v -> toPublisher(v.records()))
.map(record -> record.get("x").asInt()));
})))
return Multi.createFrom().publisher(result)
.flatMap(ReactiveResult::records)
.map(record -> record.get("x").asInt());
}))
.withFinalizer(session -> {
return Uni.createFrom().publisher(toPublisher(session.close()));
return Uni.createFrom().publisher(session.close());
});
}

Expand Down
Original file line number Diff line number Diff line change
@@ -1,23 +1,21 @@
// tag::get[]
package io.quarkus.it.neo4j;

import static org.reactivestreams.FlowAdapters.toFlowPublisher;
import static org.reactivestreams.FlowAdapters.toPublisher;

import java.util.Map;
import java.util.concurrent.Flow;

import javax.inject.Inject;
import javax.ws.rs.Consumes;
import javax.ws.rs.GET;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
import jakarta.inject.Inject;
import jakarta.ws.rs.Consumes;
import jakarta.ws.rs.GET;
import jakarta.ws.rs.POST;
import jakarta.ws.rs.Path;
import jakarta.ws.rs.Produces;
import jakarta.ws.rs.core.MediaType;

import org.jboss.resteasy.reactive.ResponseStatus;
import org.neo4j.driver.Driver;
import org.neo4j.driver.reactive.ReactiveResult;
import org.neo4j.driver.reactive.ReactiveSession;
import org.reactivestreams.Publisher;

import io.smallrye.mutiny.Multi;
import io.smallrye.mutiny.Uni;
Expand All @@ -30,19 +28,18 @@ public class ReactiveFruitResource {
Driver driver;

static Uni<Void> sessionFinalizer(ReactiveSession session) { // <.>
return Uni.createFrom().publisher(toPublisher(session.close()));
return Uni.createFrom().publisher(session.close());
}

@GET
@Produces(MediaType.SERVER_SENT_EVENTS)
public Publisher<String> get() {
public Flow.Publisher<String> get() {
// Create a stream from a resource we can close in a finalizer...
return Multi.createFrom().resource(() -> driver.session(ReactiveSession.class), // <.>
session -> toPublisher(session.executeRead(tx -> {
session -> session.executeRead(tx -> {
var result = tx.run("MATCH (f:Fruit) RETURN f.name as name ORDER BY f.name");
return toFlowPublisher(
Multi.createFrom().publisher(toPublisher(result)).flatMap(v -> toPublisher(v.records())));
})))
return Multi.createFrom().publisher(result).flatMap(ReactiveResult::records);
}))
.withFinalizer(ReactiveFruitResource::sessionFinalizer) // <.>
.map(record -> record.get("name").asString());
}
Expand All @@ -55,13 +52,12 @@ public Publisher<String> get() {
public Uni<String> create(Fruit fruit) {

return Uni.createFrom().emitter(e -> Multi.createFrom().resource(() -> driver.session(ReactiveSession.class), // <.>
session -> toPublisher(session.executeWrite(tx -> {
session -> session.executeWrite(tx -> {
var result = tx.run(
"CREATE (f:Fruit {id: randomUUID(), name: $name}) RETURN f",
Map.of("name", fruit.name));
return toFlowPublisher(
Multi.createFrom().publisher(toPublisher(result)).flatMap(v -> toPublisher(v.records())));
})))
return Multi.createFrom().publisher(result).flatMap(ReactiveResult::records);
}))
.withFinalizer(ReactiveFruitResource::sessionFinalizer)
.map(record -> Fruit.from(record.get("f").asNode()))
.subscribe().with( // <.>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
import java.util.stream.Collectors;
import java.util.stream.Stream;

import javax.ws.rs.core.Response.Status;
import jakarta.ws.rs.core.Response.Status;

import org.hamcrest.Matcher;
import org.junit.jupiter.api.AfterAll;
Expand Down
4 changes: 2 additions & 2 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
</parent>
<groupId>io.quarkiverse.neo4j</groupId>
<artifactId>quarkus-neo4j-parent</artifactId>
<version>2.2.8-SNAPSHOT</version>
<version>3.0.0-SNAPSHOT</version>
<packaging>pom</packaging>
<name>Quarkus - Neo4j - Parent</name>
<modules>
Expand All @@ -24,7 +24,7 @@
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<quarkus.version>2.16.6.Final</quarkus.version>
<quarkus.version>3.0.0.Final</quarkus.version>
<assertj.version>3.24.2</assertj.version>

<neo4j-java-driver.version>5.7.0</neo4j-java-driver.version>
Expand Down
2 changes: 1 addition & 1 deletion runtime/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
<parent>
<groupId>io.quarkiverse.neo4j</groupId>
<artifactId>quarkus-neo4j-parent</artifactId>
<version>2.2.8-SNAPSHOT</version>
<version>3.0.0-SNAPSHOT</version>
</parent>
<artifactId>quarkus-neo4j</artifactId>
<name>Quarkus - Neo4j - Runtime</name>
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.quarkus.neo4j.runtime.health;

import javax.enterprise.context.ApplicationScoped;
import javax.inject.Inject;
import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;

import org.eclipse.microprofile.health.HealthCheck;
import org.eclipse.microprofile.health.HealthCheckResponse;
Expand Down

0 comments on commit 80ed981

Please sign in to comment.