Commit 75ed7349 authored by Anastasios Poimenidis's avatar Anastasios Poimenidis
Browse files

fix: add @Blocking annotations in all signal handlers

parent 7ff87da3

src/main/java/signal/handlers/EndUserServiceUpdateSignalHandler.java

+2 −0
Changes for src/main/java/signal/handlers/EndUserServiceUpdateSignalHandler.java: 2 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -7,6 +7,7 @@ import com.fasterxml.jackson.databind.DeserializationFeature; 
import com.fasterxml.jackson.databind.ObjectMapper;

import com.fasterxml.jackson.databind.SerializationFeature;

import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;

import io.smallrye.reactive.messaging.annotations.Blocking;

import io.smallrye.reactive.messaging.kafka.api.IncomingKafkaRecordMetadata;

import jakarta.enterprise.context.ApplicationScoped;

import jakarta.inject.Inject;
@@ -40,6 +41,7 @@ public class EndUserServiceUpdateSignalHandler { 
                    .registerModule(new JavaTimeModule());



    @Incoming(SONATA_SERVICE_UPDATE)

    @Blocking

    public CompletionStage<Void> handle(Message<String> msg) {

        try {

            ServiceOrderData serviceOrderData = parse(msg.getPayload());

src/main/java/signal/handlers/PlatformServiceUpdateSignalHandler.java

+2 −0
Changes for src/main/java/signal/handlers/PlatformServiceUpdateSignalHandler.java: 2 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -7,6 +7,7 @@ import com.fasterxml.jackson.databind.DeserializationFeature; 
import com.fasterxml.jackson.databind.ObjectMapper;

import com.fasterxml.jackson.databind.SerializationFeature;

import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;

import io.smallrye.reactive.messaging.annotations.Blocking;

import io.smallrye.reactive.messaging.kafka.api.IncomingKafkaRecordMetadata;

import jakarta.enterprise.context.ApplicationScoped;

import jakarta.inject.Inject;
@@ -39,6 +40,7 @@ public class PlatformServiceUpdateSignalHandler { 
                    .registerModule(new JavaTimeModule());



    @Incoming(TMF_PLATFORM_SERVICE_UPDATE)

    @Blocking

    public CompletionStage<Void> handle(Message<String> msg) {

        try {

            PlatformServiceUpdateData platformServiceUpdateData = parse(msg.getPayload());

src/main/java/signal/handlers/ServiceActivationSignalHandler.java

+2 −0
Changes for src/main/java/signal/handlers/ServiceActivationSignalHandler.java: 2 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -7,6 +7,7 @@ import com.fasterxml.jackson.databind.DeserializationFeature; 
import com.fasterxml.jackson.databind.ObjectMapper;

import com.fasterxml.jackson.databind.SerializationFeature;

import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;

import io.smallrye.reactive.messaging.annotations.Blocking;

import io.smallrye.reactive.messaging.kafka.api.IncomingKafkaRecordMetadata;

import jakarta.enterprise.context.ApplicationScoped;

import jakarta.inject.Inject;
@@ -37,6 +38,7 @@ public class ServiceActivationSignalHandler { 
                    .registerModule(new JavaTimeModule());



    @Incoming(TMF_SERVICE_ACTIVATION)

    @Blocking

    public CompletionStage<Void> handle(Message<String> msg) {

        try {

            ServiceActivationData serviceActivationData = parse(msg.getPayload());

src/main/java/signal/handlers/ServiceOrderSignalHandler.java

+2 −0
Changes for src/main/java/signal/handlers/ServiceOrderSignalHandler.java: 2 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -7,6 +7,7 @@ import com.fasterxml.jackson.databind.DeserializationFeature; 
import com.fasterxml.jackson.databind.ObjectMapper;

import com.fasterxml.jackson.databind.SerializationFeature;

import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;

import io.smallrye.reactive.messaging.annotations.Blocking;

import io.smallrye.reactive.messaging.kafka.api.IncomingKafkaRecordMetadata;

import jakarta.enterprise.context.ApplicationScoped;

import jakarta.inject.Inject;
@@ -42,6 +43,7 @@ public class ServiceOrderSignalHandler { 
                    .registerModule(new JavaTimeModule());



    @Incoming(SONATA_SERVICE_ORDER)

    @Blocking

    public CompletionStage<Void> handle(Message<String> msg) {

        try {

            ServiceOrderData serviceOrderData = parse(msg.getPayload());

src/main/java/signal/handlers/ServiceRegisterKubernetesSignalHandler.java

+2 −0
Changes for src/main/java/signal/handlers/ServiceRegisterKubernetesSignalHandler.java: 2 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -7,6 +7,7 @@ import com.fasterxml.jackson.databind.DeserializationFeature; 
import com.fasterxml.jackson.databind.ObjectMapper;

import com.fasterxml.jackson.databind.SerializationFeature;

import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;

import io.smallrye.reactive.messaging.annotations.Blocking;

import io.smallrye.reactive.messaging.kafka.api.IncomingKafkaRecordMetadata;

import jakarta.enterprise.context.ApplicationScoped;

import jakarta.inject.Inject;
@@ -39,6 +40,7 @@ public class ServiceRegisterKubernetesSignalHandler { 
                    .registerModule(new JavaTimeModule());



    @Incoming(SONATA_REGISTER_KUBERNETES)

    @Blocking

    public CompletionStage<Void> handle(Message<String> msg) {

        try {

            KubernetesData kubernetesData = parse(msg.getPayload());