using Environment instead of ConversionService

as a workaround to micronaut-projects/micronaut-core#7948
agorapulse · Jan 17, 2023 · a769a67 · a769a67
1 parent 10935b4
commit a769a67
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 17 deletions.
diff --git a/...aut-worker-queues-sqs-v1/src/main/java/com/agorapulse/worker/sqs/v1/SqsQueuesFactory.java b/...aut-worker-queues-sqs-v1/src/main/java/com/agorapulse/worker/sqs/v1/SqsQueuesFactory.java
@@ -27,7 +27,6 @@
 import io.micronaut.context.annotation.Factory;
 import io.micronaut.context.annotation.Requires;
 import io.micronaut.context.env.Environment;
-import io.micronaut.core.convert.ConversionService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -48,7 +47,6 @@ public JobQueues sqsQueues(
             AWSCredentialsProvider provider,
             ObjectMapper mapper,
             SimpleQueueService service,
-            Optional<ConversionService<?>> conversionService,
             Environment environment
     ) {
         try {
@@ -60,7 +58,7 @@ public JobQueues sqsQueues(
             } else if (LOGGER.isInfoEnabled()) {
                 LOGGER.info("AWS SDK is not authenticated correctly, Using local job queues");
             }
-            return new LocalQueues(conversionService);
+            return new LocalQueues(environment);
         }
     }
 

diff --git a/...aut-worker-queues-sqs-v2/src/main/java/com/agorapulse/worker/sqs/v2/SqsQueuesFactory.java b/...aut-worker-queues-sqs-v2/src/main/java/com/agorapulse/worker/sqs/v2/SqsQueuesFactory.java
@@ -25,7 +25,6 @@
 import io.micronaut.context.annotation.Factory;
 import io.micronaut.context.annotation.Requires;
 import io.micronaut.context.env.Environment;
-import io.micronaut.core.convert.ConversionService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
@@ -48,7 +47,6 @@ public JobQueues sqsQueues(
             AwsCredentialsProvider provider,
             ObjectMapper mapper,
             SimpleQueueService service,
-            Optional<ConversionService<?>> conversionService,
             Environment environment
     ) {
         try {
@@ -60,7 +58,7 @@ public JobQueues sqsQueues(
             } else if (LOGGER.isInfoEnabled()) {
                 LOGGER.info("AWS SDK is not authenticated correctly, Using local job queues");
             }
-            return new LocalQueues(conversionService);
+            return new LocalQueues(environment);
         }
     }
 

diff --git a/libs/micronaut-worker/src/main/java/com/agorapulse/worker/local/LocalQueues.java b/libs/micronaut-worker/src/main/java/com/agorapulse/worker/local/LocalQueues.java
@@ -19,13 +19,12 @@
 
 import com.agorapulse.worker.queue.JobQueues;
 import io.micronaut.context.annotation.Secondary;
-import io.micronaut.core.convert.ConversionService;
+import io.micronaut.context.env.Environment;
 import io.micronaut.core.type.Argument;
 
 import javax.inject.Named;
 import javax.inject.Singleton;
 import java.time.Duration;
-import java.util.Optional;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentLinkedDeque;
 import java.util.concurrent.ConcurrentMap;
@@ -37,10 +36,10 @@
 public class LocalQueues implements JobQueues {
 
     private final ConcurrentMap<String, ConcurrentLinkedDeque<Object>> queues = new ConcurrentHashMap<>();
-    private final ConversionService<?> conversionService;
+    private final Environment environment;
 
-    public LocalQueues(Optional<ConversionService<?>> conversionService) {
-        this.conversionService = conversionService.orElse(ConversionService.SHARED);
+    public LocalQueues(Environment environment) {
+        this.environment = environment;
     }
 
     @Override
@@ -51,7 +50,7 @@ public <T> void readMessages(String queueName, int maxNumberOfMessages, Duration
         }
 
         for (int i = 0; i < maxNumberOfMessages && !objects.isEmpty(); i++) {
-            action.accept(conversionService.convertRequired(objects.removeFirst(), argument));
+            action.accept(environment.convertRequired(objects.removeFirst(), argument));
         }
     }
 

diff --git a/libs/micronaut-worker/src/main/java/com/agorapulse/worker/processor/MethodJobProcessor.java b/libs/micronaut-worker/src/main/java/com/agorapulse/worker/processor/MethodJobProcessor.java
@@ -26,9 +26,9 @@
 import com.agorapulse.worker.configuration.MutableJobConfiguration;
 import io.micronaut.context.ApplicationContext;
 import io.micronaut.context.BeanContext;
+import io.micronaut.context.env.Environment;
 import io.micronaut.context.processor.ExecutableMethodProcessor;
 import io.micronaut.core.annotation.AnnotationValue;
-import io.micronaut.core.convert.ConversionService;
 import io.micronaut.core.naming.NameUtils;
 import io.micronaut.core.util.StringUtils;
 import io.micronaut.inject.BeanDefinition;
@@ -73,7 +73,7 @@ public class MethodJobProcessor implements ExecutableMethodProcessor<Job> {
     private final JobManager jobManager;
     private final ApplicationConfiguration applicationConfiguration;
     private final JobScheduler jobScheduler;
-    private final ConversionService<?> conversionService;
+    private final Environment environment;
     private final WorkerConfiguration workerConfiguration;
 
     /**
@@ -93,7 +93,7 @@ public MethodJobProcessor(
         JobManager jobManager,
         ApplicationConfiguration applicationConfiguration,
         JobScheduler jobScheduler,
-        Optional<ConversionService<?>> optionalConversionService,
+        Environment environment,
         WorkerConfiguration workerConfiguration
     ) {
         this.beanContext = beanContext;
@@ -102,7 +102,7 @@ public MethodJobProcessor(
         this.jobManager = jobManager;
         this.applicationConfiguration = applicationConfiguration;
         this.jobScheduler = jobScheduler;
-        this.conversionService = optionalConversionService.orElse(ConversionService.SHARED);
+        this.environment = environment;
         this.workerConfiguration = workerConfiguration;
     }
 
@@ -246,7 +246,7 @@ private String extractQueueNameFromMethod(ExecutableMethod<?, ?> method) {
     }
 
     private Duration convertDuration(String jobName, String durationString, String humanReadableProperty) {
-        Optional<Duration> converted = conversionService.convert(durationString, Duration.class);
+        Optional<Duration> converted = environment.convert(durationString, Duration.class);
 
         if (converted.isPresent()) {
             return converted.get();