From f8f4d7172135b42dd168f0d0ab94b45e8a7edb3b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Mathieu?= Date: Fri, 24 May 2024 16:40:09 +0200 Subject: [PATCH] feat: trigger and realtime trigger title --- src/main/java/io/kestra/plugin/amqp/RealtimeTrigger.java | 5 +---- src/main/java/io/kestra/plugin/amqp/Trigger.java | 2 +- 2 files changed, 2 insertions(+), 5 deletions(-) diff --git a/src/main/java/io/kestra/plugin/amqp/RealtimeTrigger.java b/src/main/java/io/kestra/plugin/amqp/RealtimeTrigger.java index 8f243e3..3cf35ee 100644 --- a/src/main/java/io/kestra/plugin/amqp/RealtimeTrigger.java +++ b/src/main/java/io/kestra/plugin/amqp/RealtimeTrigger.java @@ -42,7 +42,7 @@ @Getter @NoArgsConstructor @Schema( - title = "React to and consume messages from an AMQP queue creating one executions for each message." + title = "Consume a message in real-time from a AMQP queue via change data capture and create one execution per message." ) @Plugin( examples = { @@ -57,9 +57,6 @@ beta = true ) public class RealtimeTrigger extends AbstractTrigger implements RealtimeTriggerInterface, TriggerOutput, ConsumeBaseInterface, AmqpConnectionInterface { - @Builder.Default - private final Duration interval = Duration.ofSeconds(60); - private String url; private String host; private String port; diff --git a/src/main/java/io/kestra/plugin/amqp/Trigger.java b/src/main/java/io/kestra/plugin/amqp/Trigger.java index 1f61462..d279c33 100644 --- a/src/main/java/io/kestra/plugin/amqp/Trigger.java +++ b/src/main/java/io/kestra/plugin/amqp/Trigger.java @@ -21,7 +21,7 @@ @Getter @NoArgsConstructor @Schema( - title = "Wait for message in AMQP queue." + title = "Consume messages periodically from a AMQP queue and create one execution per batch." ) @Plugin( examples = {