diff --git a/http/http-advanced/src/main/java/io/quarkus/ts/openshift/http/HttpClientVersionResource.java b/http/http-advanced/src/main/java/io/quarkus/ts/openshift/http/HttpClientVersionResource.java index ee5addd6..6cc806a9 100644 --- a/http/http-advanced/src/main/java/io/quarkus/ts/openshift/http/HttpClientVersionResource.java +++ b/http/http-advanced/src/main/java/io/quarkus/ts/openshift/http/HttpClientVersionResource.java @@ -4,7 +4,6 @@ import javax.ws.rs.core.Response; import io.quarkus.vertx.web.Route; -import io.vertx.core.http.HttpMethod; import io.vertx.ext.web.RoutingContext; @ApplicationScoped @@ -12,7 +11,7 @@ public class HttpClientVersionResource { protected static final String HTTP_VERSION = "x-http-version"; - @Route(methods = HttpMethod.GET, path = "/httpVersion") + @Route(methods = Route.HttpMethod.GET, path = "/httpVersion") public void clientHttpVersion(RoutingContext rc) { String httpClientVersion = rc.request().version().name(); rc.response().headers().add(HTTP_VERSION, httpClientVersion); diff --git a/messaging/amqp-reactive/src/main/java/io/quarkus/ts/openshift/messaging/amqp/PriceProducer.java b/messaging/amqp-reactive/src/main/java/io/quarkus/ts/openshift/messaging/amqp/PriceProducer.java index 2a32c3a8..b560e4ea 100644 --- a/messaging/amqp-reactive/src/main/java/io/quarkus/ts/openshift/messaging/amqp/PriceProducer.java +++ b/messaging/amqp-reactive/src/main/java/io/quarkus/ts/openshift/messaging/amqp/PriceProducer.java @@ -1,13 +1,13 @@ package io.quarkus.ts.openshift.messaging.amqp; -import java.util.concurrent.TimeUnit; +import java.time.Duration; import javax.enterprise.context.ApplicationScoped; import org.eclipse.microprofile.reactive.messaging.Outgoing; import org.jboss.logging.Logger; -import io.reactivex.Flowable; +import io.smallrye.mutiny.Multi; @ApplicationScoped public class PriceProducer { @@ -15,10 +15,10 @@ public class PriceProducer { private static final Logger LOG = Logger.getLogger(PriceProducer.class.getName()); @Outgoing("generated-price") - public Flowable generate() { + public Multi generate() { LOG.info("generate fired..."); - return Flowable.interval(1, TimeUnit.SECONDS) - .onBackpressureDrop() + return Multi.createFrom().ticks().every(Duration.ofSeconds(1)) + .onOverflow().drop() .map(tick -> ((tick.intValue() * 10) % 100) + 10); } } diff --git a/messaging/artemis-jta/src/main/java/io/quarkus/ts/openshift/messaging/artemisjta/ConsumerService.java b/messaging/artemis-jta/src/main/java/io/quarkus/ts/openshift/messaging/artemisjta/ConsumerService.java index 8693a168..cb6ff064 100644 --- a/messaging/artemis-jta/src/main/java/io/quarkus/ts/openshift/messaging/artemisjta/ConsumerService.java +++ b/messaging/artemis-jta/src/main/java/io/quarkus/ts/openshift/messaging/artemisjta/ConsumerService.java @@ -9,7 +9,6 @@ import javax.jms.Message; import javax.jms.Session; -import org.apache.commons.lang3.StringUtils; import org.jboss.logging.Logger; @ApplicationScoped @@ -41,7 +40,7 @@ public String receiveAndAck(boolean ackIt) throws JMSException { } private String receiveMessagesInQueue(String queueName) { - String price = StringUtils.EMPTY; + String price = ""; try (JMSContext context = connectionFactory.createContext(Session.AUTO_ACKNOWLEDGE); JMSConsumer consumer = context.createConsumer(context.createQueue(queueName))) { Message message = consumer.receive(500); diff --git a/messaging/kafka-avro-reactive-messaging/pom.xml b/messaging/kafka-avro-reactive-messaging/pom.xml index 5c3f9cfd..828774e0 100644 --- a/messaging/kafka-avro-reactive-messaging/pom.xml +++ b/messaging/kafka-avro-reactive-messaging/pom.xml @@ -83,6 +83,7 @@ build + generate-code @@ -91,10 +92,6 @@ org.apache.maven.plugins maven-failsafe-plugin - - org.apache.avro - avro-maven-plugin - diff --git a/pom.xml b/pom.xml index 9f0b6927..8c69a956 100644 --- a/pom.xml +++ b/pom.xml @@ -20,8 +20,9 @@ messaging/artemis messaging/artemis-jta messaging/amqp-reactive - messaging/kafka-avro-reactive-messaging - messaging/kafka-streams-reactive-messaging + + + messaging/qpid scaling sql-db/app @@ -53,11 +54,11 @@ true - 1.8 - 1.8 + 11 + 11 UTF-8 UTF-8 - quarkus-universe-bom + quarkus-bom io.quarkus 1.3.2.Final 0.0.2 @@ -68,12 +69,13 @@ 1.6.1 1.0.8 0.11.2 + 0.24.0 1.10.2 1.5 3.8.1 3.2.0 2.22.2 - 1.13.3.Final + 2.0.0.Alpha1 ${version.quarkus} 1.15.3 2.9.0 @@ -168,6 +170,11 @@ retrofit ${version.com.squareup.retrofit2} + + org.amqphub.quarkus + quarkus-qpid-jms + ${version.quarkus.qpid.jms} + @@ -248,6 +255,7 @@ build + generate-code @@ -302,24 +310,6 @@ jandex-maven-plugin ${version.jandex-maven-plugin} - - org.apache.avro - avro-maven-plugin - ${version.apache.avro} - - - generate-sources - - schema - - - src/main/avro - ${project.build.directory}/generated-sources - String - - - -