(camel) branch main updated: Calling super.doStart() after initializing the consumer to avoid poll() (#13867)

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new bfd2fd31d82 Calling super.doStart() after initializing the consumer to 
avoid poll() (#13867)
bfd2fd31d82 is described below

commit bfd2fd31d82929d7fa2ec7ef1a61a18586f70c7b
Author: Bahaa Zaid <bahaa.z...@pixelogicmedia.com>
AuthorDate: Tue Apr 23 11:38:55 2024 +0200

    Calling super.doStart() after initializing the consumer to avoid poll() 
(#13867)
    
    being called before the Consumer is initialized.
---
 .../component/pg/replication/slot/PgReplicationSlotConsumer.java      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotConsumer.java
 
b/components/camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotConsumer.java
index 28b11762148..0c1882670a9 100644
--- 
a/components/camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotConsumer.java
+++ 
b/components/camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotConsumer.java
@@ -62,14 +62,14 @@ public class PgReplicationSlotConsumer extends 
ScheduledPollConsumer {
 
     @Override
     protected void doStart() throws Exception {
-        super.doStart();
-
         this.connect();
 
         if (this.scheduledExecutor == null) {
             this.scheduledExecutor = 
this.getEndpoint().getCamelContext().getExecutorServiceManager()
                     .newSingleThreadScheduledExecutor(this, 
"PgReplicationStatusUpdateSender");
         }
+
+        super.doStart();
     }
 
     @Override