Yeahsper/rabbitmq-quarkus
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Cleaned up a bit more

Browse source
This commit is contained in:
Jesper Saastamoinen 2025-11-04 10:59:47 +01:00
parent 524ca47f16
commit 1b6187370f
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
rabbitmq-aver/src/main/java/se/saasta/rabbitmq/processor/AkkaProcessor.java
View file

@ -19,8 +19,8 @@ public class AkkaProcessor {
@Incoming("akka") @Incoming("akka")
public void process(JsonObject quoteRequest) throws InterruptedException { public void process(JsonObject object) throws InterruptedException {
AkkaData data = quoteRequest.mapTo(AkkaData.class); AkkaData data = object.mapTo(AkkaData.class);
System.out.println("Received data from Akka: " + data); System.out.println("Received data from Akka: " + data);
service.saveAktor(data); service.saveAktor(data);
} }

4
rabbitmq-aver/src/main/java/se/saasta/rabbitmq/processor/StaraProcessor.java
View file

@ -18,8 +18,8 @@ public class StaraProcessor {
private Random random = new Random(); private Random random = new Random();
@Incoming("stara") @Incoming("stara")
public void process(JsonObject quoteRequest) throws InterruptedException { public void process(JsonObject object) throws InterruptedException {
StaraData data = quoteRequest.mapTo(StaraData.class); StaraData data = object.mapTo(StaraData.class);
System.out.println("Received data from Stara: " + data.toString()); System.out.println("Received data from Stara: " + data.toString());
service.persistStaraData(data); service.persistStaraData(data);