fix: updated logs to use runContext.logger() and removed unused import

Author: swagatika60

src/main/java/io/kestra/plugin/azure/eventhubs/Trigger.java

@@ -12,14 +12,11 @@
 import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.validation.constraints.NotNull;
 import lombok.*;
-import lombok.experimental.SupperBuilder;
 import lombok.experimental.SuperBuilder;
-
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-
+import java.lang.reflect.Constructor;
 import java.time.Duration;
 import java.util.Collections;
 import java.util.HashMap;
@@ -62,14 +59,14 @@
     description = "If you would like to consume each message from Azure Event Hubs in real-time and create one execution per message, you can use the [io.kestra.plugin.azure.eventhubs.RealtimeTrigger](https://kestra.io/plugins/plugin-azure/triggers/io.kestra.plugin.azure.eventhubs.realtimetrigger) instead."
 )
 
-@NoArgsConstructor
 @SuperBuilder
+@NoArgsConstructor
 @ToString
 @EqualsAndHashCode
 @Getter
 public class Trigger extends AbstractTrigger implements EventHubConsumerInterface, EventHubBatchConsumerInterface, PollingTriggerInterface, TriggerOutput<Consume.Output> {
+  
 
-runContext.logger().info("Trigger started");
 
 
     // TRIGGER'S PROPERTIES
@@ -127,19 +124,28 @@ public class Trigger extends AbstractTrigger implements EventHubConsumerInterfac
      * {@inheritDoc}
      **/
     @Override
-    public Optional<Execution> evaluate(ConditionContext conditionContext,
-                                        TriggerContext context) throws Exception {
-        RunContext runContext = conditionContext.getRunContext();
+public Optional<Execution> evaluate(ConditionContext conditionContext,
+                                    TriggerContext context) throws Exception {
 
-        final Consume task = new Consume();
-        final Consume.Output output = task.run(runContext, this);
+    RunContext runContext = conditionContext.getRunContext();
 
-        if (output.getEventsCount() == 0) {
-            return Optional.empty();
-        }
+    // Correct place for logger
+    runContext.logger().info("Trigger started");
 
-        Execution execution = TriggerService.generateExecution(this, conditionContext, context, output);
+    final Consume task = new Consume();
+    final Consume.Output output = task.run(runContext, this);
 
-        return Optional.of(execution);
+    if (output.getEventsCount() == 0) {
+        return Optional.empty();
     }
-}
+
+    Execution execution = TriggerService.generateExecution(
+            this,
+            conditionContext,
+            context,
+            output
+    );
+
+    return Optional.of(execution);
+
+}