feat: trigger and realtime trigger title

kestra-io · May 24, 2024 · 972fac7 · 972fac7
1 parent 652d259
commit 972fac7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git 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<Message>, 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
@@ -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 = {