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 = {