Logging: Remove usages of deprecated JBoss Logging API to using MethodHandles

Author: ozangunalp

smallrye-reactive-messaging-amqp/src/main/java/io/smallrye/reactive/messaging/amqp/i18n/AMQPLogging.java

@@ -1,5 +1,7 @@
 package io.smallrye.reactive.messaging.amqp.i18n;
 
+import java.lang.invoke.MethodHandles;
+
 import org.jboss.logging.BasicLogger;
 import org.jboss.logging.Logger;
 import org.jboss.logging.annotations.Cause;
@@ -14,7 +16,8 @@
 @MessageLogger(projectCode = "SRMSG", length = 5)
 public interface AMQPLogging extends BasicLogger {
 
-    AMQPLogging log = Logger.getMessageLogger(AMQPLogging.class, "io.smallrye.reactive.messaging.amqp");
+    AMQPLogging log = Logger.getMessageLogger(MethodHandles.lookup(), AMQPLogging.class,
+            "io.smallrye.reactive.messaging.amqp");
 
     @LogMessage(level = Logger.Level.DEBUG)
     @Message(id = 16200, value = "Creating AMQP client from bean named '%s'")

smallrye-reactive-messaging-aws-sqs/src/main/java/io/smallrye/reactive/messaging/aws/sqs/i18n/AwsSqsLogging.java

@@ -1,5 +1,7 @@
 package io.smallrye.reactive.messaging.aws.sqs.i18n;
 
+import java.lang.invoke.MethodHandles;
+
 import org.jboss.logging.BasicLogger;
 import org.jboss.logging.Logger;
 import org.jboss.logging.Logger.Level;
@@ -14,7 +16,9 @@
  */
 @MessageLogger(projectCode = "SRMSG", length = 5)
 public interface AwsSqsLogging extends BasicLogger {
-    AwsSqsLogging log = Logger.getMessageLogger(AwsSqsLogging.class, "io.smallrye.reactive.messaging.aws.sqs");
+
+    AwsSqsLogging log = Logger.getMessageLogger(MethodHandles.lookup(), AwsSqsLogging.class,
+            "io.smallrye.reactive.messaging.aws.sqs");
 
     @LogMessage(level = Level.TRACE)
     @Message(id = 19300, value = "Received Aws Sqs message %s")

smallrye-reactive-messaging-camel/src/main/java/io/smallrye/reactive/messaging/camel/i18n/CamelLogging.java

@@ -1,5 +1,7 @@
 package io.smallrye.reactive.messaging.camel.i18n;
 
+import java.lang.invoke.MethodHandles;
+
 import org.jboss.logging.BasicLogger;
 import org.jboss.logging.Logger;
 import org.jboss.logging.annotations.Cause;
@@ -14,7 +16,8 @@
 @MessageLogger(projectCode = "SRMSG", length = 5)
 public interface CamelLogging extends BasicLogger {
 
-    CamelLogging log = Logger.getMessageLogger(CamelLogging.class, "io.smallrye.reactive.messaging.camel");
+    CamelLogging log = Logger.getMessageLogger(MethodHandles.lookup(), CamelLogging.class,
+            "io.smallrye.reactive.messaging.camel");
 
     @LogMessage(level = Logger.Level.INFO)
     @Message(id = 17800, value = "Creating publisher from Camel stream named %s")

smallrye-reactive-messaging-gcp-pubsub/src/main/java/io/smallrye/reactive/messaging/gcp/pubsub/i18n/PubSubLogging.java

@@ -1,5 +1,7 @@
 package io.smallrye.reactive.messaging.gcp.pubsub.i18n;
 
+import java.lang.invoke.MethodHandles;
+
 import org.jboss.logging.BasicLogger;
 import org.jboss.logging.Logger;
 import org.jboss.logging.annotations.Cause;
@@ -17,7 +19,8 @@
 @MessageLogger(projectCode = "SRMSG", length = 5)
 public interface PubSubLogging extends BasicLogger {
 
-    PubSubLogging log = Logger.getMessageLogger(PubSubLogging.class, "io.smallrye.reactive.messaging.gcp.pubsub");
+    PubSubLogging log = Logger.getMessageLogger(MethodHandles.lookup(), PubSubLogging.class,
+            "io.smallrye.reactive.messaging.gcp.pubsub");
 
     @LogMessage(level = Logger.Level.TRACE)
     @Message(id = 14800, value = "Topic %s already exists")

smallrye-reactive-messaging-in-memory/src/main/java/io/smallrye/reactive/messaging/memory/i18n/InMemoryLogging.java

@@ -1,5 +1,7 @@
 package io.smallrye.reactive.messaging.memory.i18n;
 
+import java.lang.invoke.MethodHandles;
+
 import org.jboss.logging.BasicLogger;
 import org.jboss.logging.Logger;
 import org.jboss.logging.annotations.MessageLogger;
@@ -11,5 +13,6 @@
 @MessageLogger(projectCode = "SRMSG", length = 5)
 public interface InMemoryLogging extends BasicLogger {
 
-    InMemoryLogging log = Logger.getMessageLogger(InMemoryLogging.class, "io.smallrye.reactive.messaging.in-memory");
+    InMemoryLogging log = Logger.getMessageLogger(MethodHandles.lookup(), InMemoryLogging.class,
+            "io.smallrye.reactive.messaging.in-memory");
 }

smallrye-reactive-messaging-jms/src/main/java/io/smallrye/reactive/messaging/jms/i18n/JmsLogging.java

@@ -1,5 +1,7 @@
 package io.smallrye.reactive.messaging.jms.i18n;
 
+import java.lang.invoke.MethodHandles;
+
 import org.jboss.logging.BasicLogger;
 import org.jboss.logging.Logger;
 import org.jboss.logging.annotations.Cause;
@@ -14,7 +16,8 @@
 @MessageLogger(projectCode = "SRMSG", length = 5)
 public interface JmsLogging extends BasicLogger {
 
-    JmsLogging log = Logger.getMessageLogger(JmsLogging.class, "io.smallrye.reactive.messaging.jms");
+    JmsLogging log = Logger.getMessageLogger(MethodHandles.lookup(), JmsLogging.class,
+            "io.smallrye.reactive.messaging.jms");
 
     @LogMessage(level = Logger.Level.ERROR)
     @Message(id = 15800, value = "Unable to send message to JMS")

smallrye-reactive-messaging-kafka/src/main/java/io/smallrye/reactive/messaging/kafka/i18n/KafkaLogging.java

@@ -1,5 +1,6 @@
 package io.smallrye.reactive.messaging.kafka.i18n;
 
+import java.lang.invoke.MethodHandles;
 import java.util.Collection;
 import java.util.Map;
 import java.util.Set;
@@ -20,7 +21,8 @@
 @MessageLogger(projectCode = "SRMSG", length = 5)
 public interface KafkaLogging extends BasicLogger {
 
-    KafkaLogging log = Logger.getMessageLogger(KafkaLogging.class, "io.smallrye.reactive.messaging.kafka");
+    KafkaLogging log = Logger.getMessageLogger(MethodHandles.lookup(), KafkaLogging.class,
+            "io.smallrye.reactive.messaging.kafka");
 
     @LogMessage(level = Logger.Level.DEBUG)
     @Message(id = 18201, value = "Dead queue letter configured with: topic: `%s`, key serializer: `%s`, value serializer: `%s`")

smallrye-reactive-messaging-mqtt/src/main/java/io/smallrye/reactive/messaging/mqtt/i18n/MqttLogging.java

@@ -1,5 +1,7 @@
 package io.smallrye.reactive.messaging.mqtt.i18n;
 
+import java.lang.invoke.MethodHandles;
+
 import org.jboss.logging.BasicLogger;
 import org.jboss.logging.Logger;
 import org.jboss.logging.annotations.Cause;
@@ -16,7 +18,7 @@ public interface MqttLogging extends BasicLogger {
 
     // 17100-17199 (logging)
 
-    MqttLogging log = Logger.getMessageLogger(MqttLogging.class, "io.smallrye.reactive.messaging.mqtt");
+    MqttLogging log = Logger.getMessageLogger(MethodHandles.lookup(), MqttLogging.class, "io.smallrye.reactive.messaging.mqtt");
 
     @LogMessage(level = Logger.Level.ERROR)
     @Message(id = 17100, value = "A message sent to channel `%s` has been nacked, fail-stop")

smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/i18n/ProviderLogging.java

@@ -1,5 +1,6 @@
 package io.smallrye.reactive.messaging.providers.i18n;
 
+import java.lang.invoke.MethodHandles;
 import java.util.Set;
 
 import jakarta.enterprise.inject.spi.Bean;
@@ -19,7 +20,8 @@ public interface ProviderLogging extends BasicLogger {
 
     // 00200-00299 (logging)
 
-    ProviderLogging log = Logger.getMessageLogger(ProviderLogging.class, "io.smallrye.reactive.messaging.provider");
+    ProviderLogging log = Logger.getMessageLogger(MethodHandles.lookup(), ProviderLogging.class,
+            "io.smallrye.reactive.messaging.provider");
 
     @LogMessage(level = Logger.Level.ERROR)
     @Message(id = 200, value = "The method %s has thrown an exception")

smallrye-reactive-messaging-pulsar/src/main/java/io/smallrye/reactive/messaging/pulsar/i18n/PulsarLogging.java

@@ -1,5 +1,7 @@
 package io.smallrye.reactive.messaging.pulsar.i18n;
 
+import java.lang.invoke.MethodHandles;
+
 import org.jboss.logging.BasicLogger;
 import org.jboss.logging.Logger;
 import org.jboss.logging.annotations.Cause;
@@ -14,7 +16,8 @@
 @MessageLogger(projectCode = "SRMSG", length = 5)
 public interface PulsarLogging extends BasicLogger {
 
-    PulsarLogging log = Logger.getMessageLogger(PulsarLogging.class, "io.smallrye.reactive.messaging.pulsar");
+    PulsarLogging log = Logger.getMessageLogger(MethodHandles.lookup(), PulsarLogging.class,
+            "io.smallrye.reactive.messaging.pulsar");
 
     @LogMessage(level = Logger.Level.WARN)
     @Message(id = 19000, value = "Unable to close Pulsar consumer")