Skip to content

Commit 874290d

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

File tree

15 files changed

+11
-18
lines changed

15 files changed

+11
-18
lines changed

build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -282,7 +282,7 @@ shadowJar {
282282
exclude {
283283
it.moduleGroup.startsWith('com.fasterxml.jackson') && !it.moduleName.equals('jackson-datatype-joda')
284284
}
285-
exclude "org/slf4j/**"
285+
exclude "org/slf4j/**"
286286
}
287287
}
288288

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
import jakarta.validation.constraints.NotNull;
2828
import lombok.*;
2929
import lombok.experimental.SuperBuilder;
30+
import org.slf4j.Logger;
3031

3132

3233
import java.io.File;

src/main/java/io/kestra/plugin/azure/batch/models/ContainerRegistry.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
21
package io.kestra.plugin.azure.batch.models;
32

43
import io.kestra.core.exceptions.IllegalVariableEvaluationException;

src/main/java/io/kestra/plugin/azure/datafactory/CreateRun.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333
import lombok.*;
3434
import lombok.experimental.SuperBuilder;
3535

36+
import org.slf4j.Logger;
3637
import reactor.core.publisher.Flux;
3738
import reactor.core.publisher.Mono;
3839

@@ -49,7 +50,6 @@
4950
import java.util.concurrent.atomic.AtomicReference;
5051

5152

52-
5353
@SuperBuilder
5454
@ToString
5555
@EqualsAndHashCode

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333
import lombok.NoArgsConstructor;
3434
import lombok.ToString;
3535
import lombok.experimental.SuperBuilder;
36+
import org.slf4j.Logger;
3637

3738

3839
import java.io.BufferedOutputStream;
@@ -78,7 +79,6 @@
7879
@Schema(
7980
title = "Consume events from Azure Event Hubs."
8081
)
81-
8282
@SuperBuilder
8383
@NoArgsConstructor
8484
@Getter

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* This class provides all required and optional parameters.
1616
*/
1717
public interface EventHubConsumerInterface extends EventHubClientInterface {
18-
18+
1919
// TASK'S PARAMETERS
2020
@Schema(
2121
title = "The Deserializer to be used for serializing the event value."

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,6 @@
8686
@Schema(
8787
title = "Publish events to Azure Event Hubs."
8888
)
89-
9089
@SuperBuilder
9190
@Getter
9291
@NoArgsConstructor

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,6 @@
102102
title = "Trigger a flow on message consumption in real-time from Azure Event Hubs.",
103103
description = "If you would like to consume multiple messages processed within a given time frame and process them in batch, you can use the [io.kestra.plugin.azure.eventhubs.Trigger](https://kestra.io/plugins/plugin-azure/triggers/io.kestra.plugin.azure.eventhubs.trigger) instead."
104104
)
105-
106105
@NoArgsConstructor
107106
@SuperBuilder
108107
@ToString

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

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -12,16 +12,10 @@
1212
import io.swagger.v3.oas.annotations.media.Schema;
1313
import jakarta.validation.constraints.NotNull;
1414
import lombok.*;
15-
import lombok.experimental.SupperBuilder;
1615
import lombok.experimental.SuperBuilder;
1716

1817

19-
import org.slf4j.Logger;
20-
import org.slf4j.LoggerFactory;
21-
22-
2318
import java.time.Duration;
24-
import java.util.Collections;
2519
import java.util.HashMap;
2620
import java.util.Map;
2721
import java.util.Optional;
@@ -69,9 +63,6 @@
6963
@Getter
7064
public class Trigger extends AbstractTrigger implements EventHubConsumerInterface, EventHubBatchConsumerInterface, PollingTriggerInterface, TriggerOutput<Consume.Output> {
7165

72-
runContext.logger().info("Trigger started");
73-
74-
7566
// TRIGGER'S PROPERTIES
7667
@Builder.Default
7768
private Duration interval = Duration.ofSeconds(60);

src/main/java/io/kestra/plugin/azure/eventhubs/client/EventHubClientFactory.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
import java.util.Optional;
2525

2626
public class EventHubClientFactory {
27-
2827
private static final Logger log = LoggerFactory.getLogger(EventHubClientFactory.class);
2928

3029

0 commit comments

Comments
 (0)