diff --git a/rabbitmq-akka/src/main/java/se/saasta/rabbitmq/producer/UpdateAktorCronJob.java b/rabbitmq-akka/src/main/java/se/saasta/rabbitmq/producer/UpdateAktorCronJob.java index 63d17b2..a38e029 100644 --- a/rabbitmq-akka/src/main/java/se/saasta/rabbitmq/producer/UpdateAktorCronJob.java +++ b/rabbitmq-akka/src/main/java/se/saasta/rabbitmq/producer/UpdateAktorCronJob.java @@ -15,11 +15,11 @@ public class UpdateAktorCronJob { Emitter emitter; @Scheduled(cron = "{cron.expr}") - void cronJobWithExpressionInConfig() { + void cronJobCreateActor() { AkkaData akkaData = new AkkaData(); UUID uuid = UUID.randomUUID(); akkaData.setOrgnr(uuid.toString()); emitter.send(akkaData); - System.out.println("Emitted that actor was updated"); + System.out.println("Emitted that actor was created"); } } \ No newline at end of file diff --git a/rabbitmq-aver/src/main/java/se/saasta/rabbitmq/model/StaraData.java b/rabbitmq-aver/src/main/java/se/saasta/rabbitmq/model/StaraData.java index 6716345..56f7af3 100644 --- a/rabbitmq-aver/src/main/java/se/saasta/rabbitmq/model/StaraData.java +++ b/rabbitmq-aver/src/main/java/se/saasta/rabbitmq/model/StaraData.java @@ -1,6 +1,5 @@ package se.saasta.rabbitmq.model; -import com.fasterxml.jackson.annotation.JsonIgnore; import io.quarkus.runtime.annotations.RegisterForReflection; import java.util.List; @@ -8,18 +7,9 @@ import java.util.List; @RegisterForReflection public class StaraData { - @JsonIgnore - private long id; private long amount; private List orgnr; - public long getId() { - return id; - } - - public void setId(long id) { - this.id = id; - } public long getAmount() { return amount; @@ -40,8 +30,7 @@ public class StaraData { @Override public String toString() { return "StaraData{" + - "id=" + id + - ", amount=" + amount + + "amount=" + amount + ", orgnr=" + orgnr + '}'; } diff --git a/rabbitmq-aver/src/main/java/se/saasta/rabbitmq/processor/StaraProcessor.java b/rabbitmq-aver/src/main/java/se/saasta/rabbitmq/processor/StaraProcessor.java index bb487f9..4433b6a 100644 --- a/rabbitmq-aver/src/main/java/se/saasta/rabbitmq/processor/StaraProcessor.java +++ b/rabbitmq-aver/src/main/java/se/saasta/rabbitmq/processor/StaraProcessor.java @@ -20,7 +20,7 @@ public class StaraProcessor { @Incoming("stara") public void process(JsonObject quoteRequest) throws InterruptedException { StaraData data = quoteRequest.mapTo(StaraData.class); - System.out.println("RECEIVED DATA WOOP WOOP: " + data.toString()); + System.out.println("Received data from Stara: " + data.toString()); service.persistStaraData(data); } diff --git a/rabbitmq-aver/src/main/resources/application.properties b/rabbitmq-aver/src/main/resources/application.properties index f51e0de..62eca49 100644 --- a/rabbitmq-aver/src/main/resources/application.properties +++ b/rabbitmq-aver/src/main/resources/application.properties @@ -5,7 +5,4 @@ mp.messaging.incoming.stara.exchange.name=stara mp.messaging.incoming.akka.connector=smallrye-rabbitmq mp.messaging.incoming.akka.queue.name=akka mp.messaging.incoming.akka.exchange.name=akka -# Configure the outgoing RabbitMQ exchange `quotes` -mp.messaging.outgoing.quotes.connector=smallrye-rabbitmq -mp.messaging.outgoing.quotes.exchange.name=stara quarkus.http.port=8081 \ No newline at end of file diff --git a/rabbitmq-stara/README.md b/rabbitmq-stara/README.md index b9b973b..e69de29 100644 --- a/rabbitmq-stara/README.md +++ b/rabbitmq-stara/README.md @@ -1,59 +0,0 @@ -# rabbitmq-quickstart-producer - -This project uses Quarkus, the Supersonic Subatomic Java Framework. - -If you want to learn more about Quarkus, please visit its website: . - -## Running the application in dev mode - -You can run your application in dev mode that enables live coding using: - -```shell script -./mvnw quarkus:dev -``` - -> **_NOTE:_** Quarkus now ships with a Dev UI, which is available in dev mode only at . - -## Packaging and running the application - -The application can be packaged using: - -```shell script -./mvnw package -``` - -It produces the `quarkus-run.jar` file in the `target/quarkus-app/` directory. -Be aware that it’s not an _über-jar_ as the dependencies are copied into the `target/quarkus-app/lib/` directory. - -The application is now runnable using `java -jar target/quarkus-app/quarkus-run.jar`. - -If you want to build an _über-jar_, execute the following command: - -```shell script -./mvnw package -Dquarkus.package.jar.type=uber-jar -``` - -The application, packaged as an _über-jar_, is now runnable using `java -jar target/*-runner.jar`. - -## Creating a native executable - -You can create a native executable using: - -```shell script -./mvnw package -Dnative -``` - -Or, if you don't have GraalVM installed, you can run the native executable build in a container using: - -```shell script -./mvnw package -Dnative -Dquarkus.native.container-build=true -``` - -You can then execute your native executable with: `./target/rabbitmq-quickstart-producer-1.0.0-SNAPSHOT-runner` - -If you want to learn more about building native executables, please consult . - -## Related Guides - -- REST Jackson ([guide](https://quarkus.io/guides/rest#json-serialisation)): Jackson serialization support for Quarkus REST. This extension is not compatible with the quarkus-resteasy extension, or any of the extensions that depend on it -- Messaging - RabbitMQ Connector ([guide](https://quarkus.io/guides/rabbitmq)): Connect to RabbitMQ with Reactive Messaging diff --git a/rabbitmq-stara/src/main/java/se/saasta/rabbitmq/producer/StaraResource.java b/rabbitmq-stara/src/main/java/se/saasta/rabbitmq/producer/StaraResource.java index 67b84cd..581e33e 100644 --- a/rabbitmq-stara/src/main/java/se/saasta/rabbitmq/producer/StaraResource.java +++ b/rabbitmq-stara/src/main/java/se/saasta/rabbitmq/producer/StaraResource.java @@ -1,7 +1,6 @@ package se.saasta.rabbitmq.producer; -import io.smallrye.mutiny.Multi; import jakarta.ws.rs.Consumes; import jakarta.ws.rs.POST; import jakarta.ws.rs.Path; @@ -19,14 +18,10 @@ import java.util.UUID; @Path("/stara") public class StaraResource { - + @Channel("stara") Emitter emitter; - - @Channel("aver") - Multi quotes; - @POST @Produces(MediaType.APPLICATION_JSON) @Consumes(MediaType.APPLICATION_JSON) diff --git a/rabbitmq-stara/src/main/resources/application.properties b/rabbitmq-stara/src/main/resources/application.properties index 53b5306..ce413d4 100644 --- a/rabbitmq-stara/src/main/resources/application.properties +++ b/rabbitmq-stara/src/main/resources/application.properties @@ -1,3 +1,3 @@ -mp.messaging.outgoing.quote-requests.connector=smallrye-rabbitmq -mp.messaging.outgoing.quote-requests.exchange.name=quote-requests +mp.messaging.outgoing.stara.connector=smallrye-rabbitmq +mp.messaging.outgoing.stara.exchange.name=stara mp.messaging.incoming.aver.connector=smallrye-rabbitmq \ No newline at end of file