From 1b6187370f6a334c7fe220261df2dd46eed22ca6 Mon Sep 17 00:00:00 2001 From: Jesper Saastamoinen Date: Tue, 4 Nov 2025 10:59:47 +0100 Subject: [PATCH] Cleaned up a bit more --- .../main/java/se/saasta/rabbitmq/processor/AkkaProcessor.java | 4 ++-- .../java/se/saasta/rabbitmq/processor/StaraProcessor.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/rabbitmq-aver/src/main/java/se/saasta/rabbitmq/processor/AkkaProcessor.java b/rabbitmq-aver/src/main/java/se/saasta/rabbitmq/processor/AkkaProcessor.java index 764f75a..e3cd12b 100644 --- a/rabbitmq-aver/src/main/java/se/saasta/rabbitmq/processor/AkkaProcessor.java +++ b/rabbitmq-aver/src/main/java/se/saasta/rabbitmq/processor/AkkaProcessor.java @@ -19,8 +19,8 @@ public class AkkaProcessor { @Incoming("akka") - public void process(JsonObject quoteRequest) throws InterruptedException { - AkkaData data = quoteRequest.mapTo(AkkaData.class); + public void process(JsonObject object) throws InterruptedException { + AkkaData data = object.mapTo(AkkaData.class); System.out.println("Received data from Akka: " + data); service.saveAktor(data); } 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 4433b6a..2801edd 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 @@ -18,8 +18,8 @@ public class StaraProcessor { private Random random = new Random(); @Incoming("stara") - public void process(JsonObject quoteRequest) throws InterruptedException { - StaraData data = quoteRequest.mapTo(StaraData.class); + public void process(JsonObject object) throws InterruptedException { + StaraData data = object.mapTo(StaraData.class); System.out.println("Received data from Stara: " + data.toString()); service.persistStaraData(data);