Skip to content

Commit e183f29

Browse files
refactor: Reapply @slf4j cleanup for Azure plugin classes
1 parent 874290d commit e183f29

File tree

6 files changed

+1
-10
lines changed

6 files changed

+1
-10
lines changed

src/main/java/io/kestra/plugin/azure/batch/job/Create.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@
2929
import lombok.experimental.SuperBuilder;
3030
import org.slf4j.Logger;
3131

32-
3332
import java.io.File;
3433
import java.io.IOException;
3534
import java.net.URI;

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

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,12 @@
11
package io.kestra.plugin.azure.eventhubs;
22

3-
import io.kestra.core.models.annotations.PluginProperty;
43
import io.kestra.core.models.property.Property;
54
import io.kestra.plugin.azure.eventhubs.serdes.Serdes;
65
import io.kestra.plugin.azure.eventhubs.service.consumer.StartingPosition;
76
import io.swagger.v3.oas.annotations.media.Schema;
87

9-
import java.time.Duration;
108
import java.util.Map;
119

12-
1310
/**
1411
* Base class for implementing tasks that consume events into EventHubs.
1512
* This class provides all required and optional parameters.

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,13 +19,11 @@
1919
import io.swagger.v3.oas.annotations.media.Schema;
2020
import lombok.*;
2121
import lombok.experimental.SuperBuilder;
22-
import lombok.extern.slf4j.Slf4j;
2322
import org.reactivestreams.Publisher;
2423
import org.slf4j.Logger;
2524
import reactor.core.publisher.Flux;
2625

2726
import java.time.Duration;
28-
import java.util.Collections;
2927
import java.util.HashMap;
3028
import java.util.Map;
3129
import java.util.concurrent.CountDownLatch;

src/main/java/io/kestra/plugin/azure/eventhubs/service/producer/ProducerContext.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package io.kestra.plugin.azure.eventhubs.service.producer;
22

3-
43
import org.slf4j.Logger;
54

65
import java.util.Map;
@@ -15,6 +14,6 @@
1514
public record ProducerContext(String bodyContentType,
1615
Map<String, String> eventProperties,
1716
Integer maxEventsPerBatch,
18-
Logger logger
17+
Logger logger
1918
) {
2019
}

src/test/java/io/kestra/plugin/azure/batch/job/CreateTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@
1515
import jakarta.inject.Named;
1616
import org.junit.jupiter.api.Disabled;
1717
import org.junit.jupiter.api.Test;
18-
1918
import org.slf4j.event.Level;
2019
import reactor.core.publisher.Flux;
2120

src/test/java/io/kestra/plugin/azure/eventhubs/service/producer/EventHubProducerServiceTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020
import org.mockito.Mockito;
2121
import org.mockito.junit.jupiter.MockitoExtension;
2222
import org.mockito.stubbing.Answer;
23-
2423
import org.slf4j.Logger;
2524
import org.slf4j.LoggerFactory;
2625
import reactor.core.publisher.Mono;

0 commit comments

Comments
 (0)