[camel] branch master updated: Fix camel-pg-replication-slot PgReplicationSlotCamelTest

[ja...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 1f5f1d0  Fix camel-pg-replication-slot PgReplicationSlotCamelTest
1f5f1d0 is described below

commit 1f5f1d0cf77a885881e87e17b2bfa791c6a09c96
Author: James Netherton <ja...@gmail.com>
AuthorDate: Fri Nov 27 15:17:28 2020 +0000

    Fix camel-pg-replication-slot PgReplicationSlotCamelTest
---
 .../camel/component/pg/replication/slot/PgReplicationSlotComponent.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/components/camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotComponent.java b/components/camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotComponent.java
index 2bf712c..732a229 100644
--- a/components/camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotComponent.java
+++ b/components/camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotComponent.java
@@ -31,10 +31,10 @@ public class PgReplicationSlotComponent extends DefaultComponent {
 
     @Override
     protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
+        Map<String, Object> slotOptions = PropertiesHelper.extractProperties(parameters, "slotOptions.");
         PgReplicationSlotEndpoint endpoint = new PgReplicationSlotEndpoint(uri, this);
         setProperties(endpoint, parameters);
 
-        Map<String, Object> slotOptions = PropertiesHelper.extractProperties(parameters, "slotOptions.");
         endpoint.setSlotOptions(slotOptions);
 
         return endpoint;