default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.backoffErrorThreshold(int backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.backoffErrorThreshold(String backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.backoffIdleThreshold(int backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.backoffIdleThreshold(String backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.backoffMultiplier(int backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.backoffMultiplier(String backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.AdvancedPgReplicationSlotEndpointBuilder.basic() |
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.bridgeErrorHandler(String bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.delay(long delay) |
Milliseconds before the next poll.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.delay(String delay) |
Milliseconds before the next poll.
|
static PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.endpointBuilder(String componentName,
String path) |
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.greedy(boolean greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.greedy(String greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.initialDelay(long initialDelay) |
Milliseconds before the first poll starts.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.initialDelay(String initialDelay) |
Milliseconds before the first poll starts.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.password(String password) |
Postgres password.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotBuilders.pgReplicationSlot(String path) |
PostgresSQL Replication Slot (camel-pg-replication-slot)
Poll for PostgreSQL Write-Ahead Log (WAL) records using Streaming
Replication Slots.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotBuilders.pgReplicationSlot(String componentName,
String path) |
PostgresSQL Replication Slot (camel-pg-replication-slot)
Poll for PostgreSQL Write-Ahead Log (WAL) records using Streaming
Replication Slots.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.repeatCount(long repeatCount) |
Specifies a maximum limit of number of fires.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.repeatCount(String repeatCount) |
Specifies a maximum limit of number of fires.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.runLoggingLevel(String runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.runLoggingLevel(org.apache.camel.LoggingLevel runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.scheduledExecutorService(String scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.scheduledExecutorService(ScheduledExecutorService scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.scheduler(Object scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.scheduler(String scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.schedulerProperties(String key,
Object value) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.schedulerProperties(Map values) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.sendEmptyMessageWhenIdle(boolean sendEmptyMessageWhenIdle) |
If the polling consumer did not poll any files, you can enable this
option to send an empty message (no body) instead.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.sendEmptyMessageWhenIdle(String sendEmptyMessageWhenIdle) |
If the polling consumer did not poll any files, you can enable this
option to send an empty message (no body) instead.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.startScheduler(boolean startScheduler) |
Whether the scheduler should be auto started.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.startScheduler(String startScheduler) |
Whether the scheduler should be auto started.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.timeUnit(String timeUnit) |
Time unit for initialDelay and delay options.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.timeUnit(TimeUnit timeUnit) |
Time unit for initialDelay and delay options.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.useFixedDelay(boolean useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.useFixedDelay(String useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder |
PgReplicationSlotEndpointBuilderFactory.PgReplicationSlotEndpointBuilder.user(String user) |
Postgres user.
|