You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/04/01 11:33:19 UTC
[camel] 02/02: CAMEL-17879: remove leftovers from camel-beanstalk
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 3c6d614b3f7e2e684fd1e7eec659d4698a1ff855
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Fri Apr 1 12:26:18 2022 +0200
CAMEL-17879: remove leftovers from camel-beanstalk
---
bom/camel-bom/pom.xml | 5 -
catalog/camel-allcomponents/pom.xml | 4 -
.../component/ComponentsBuilderFactory.java | 14 -
.../dsl/BeanstalkComponentBuilderFactory.java | 165 ---
.../src/generated/resources/metadata.json | 22 -
.../builder/endpoint/EndpointBuilderFactory.java | 1 -
.../camel/builder/endpoint/EndpointBuilders.java | 1 -
.../builder/endpoint/StaticEndpointBuilders.java | 45 -
.../dsl/BeanstalkEndpointBuilderFactory.java | 1380 --------------------
parent/pom.xml | 5 -
10 files changed, 1642 deletions(-)
diff --git a/bom/camel-bom/pom.xml b/bom/camel-bom/pom.xml
index 95c899e..62117d3 100644
--- a/bom/camel-bom/pom.xml
+++ b/bom/camel-bom/pom.xml
@@ -333,11 +333,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-beanstalk</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-bindy</artifactId>
<version>${project.version}</version>
</dependency>
diff --git a/catalog/camel-allcomponents/pom.xml b/catalog/camel-allcomponents/pom.xml
index d89393d..581677c 100644
--- a/catalog/camel-allcomponents/pom.xml
+++ b/catalog/camel-allcomponents/pom.xml
@@ -239,10 +239,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-beanstalk</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-bindy</artifactId>
</dependency>
<dependency>
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
index 2f04035..bd173a1 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
@@ -628,20 +628,6 @@ public interface ComponentsBuilderFactory {
return org.apache.camel.builder.component.dsl.BeanValidatorComponentBuilderFactory.beanValidator();
}
/**
- * Beanstalk (camel-beanstalk)
- * Retrieve and post-process Beanstalk jobs.
- *
- * Category: messaging
- * Since: 2.15
- * Maven coordinates: org.apache.camel:camel-beanstalk
- *
- * @return the dsl builder
- */
- @Deprecated
- static org.apache.camel.builder.component.dsl.BeanstalkComponentBuilderFactory.BeanstalkComponentBuilder beanstalk() {
- return org.apache.camel.builder.component.dsl.BeanstalkComponentBuilderFactory.beanstalk();
- }
- /**
* Bonita (camel-bonita)
* Communicate with a remote Bonita BPM process engine.
*
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/BeanstalkComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/BeanstalkComponentBuilderFactory.java
deleted file mode 100644
index 504cfe2..0000000
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/BeanstalkComponentBuilderFactory.java
+++ /dev/null
@@ -1,165 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.builder.component.dsl;
-
-import javax.annotation.Generated;
-import org.apache.camel.Component;
-import org.apache.camel.builder.component.AbstractComponentBuilder;
-import org.apache.camel.builder.component.ComponentBuilder;
-import org.apache.camel.component.beanstalk.BeanstalkComponent;
-
-/**
- * Retrieve and post-process Beanstalk jobs.
- *
- * Generated by camel-package-maven-plugin - do not edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
-public interface BeanstalkComponentBuilderFactory {
-
- /**
- * Beanstalk (camel-beanstalk)
- * Retrieve and post-process Beanstalk jobs.
- *
- * Category: messaging
- * Since: 2.15
- * Maven coordinates: org.apache.camel:camel-beanstalk
- *
- * @return the dsl builder
- */
- @Deprecated
- static BeanstalkComponentBuilder beanstalk() {
- return new BeanstalkComponentBuilderImpl();
- }
-
- /**
- * Builder for the Beanstalk component.
- */
- interface BeanstalkComponentBuilder
- extends
- ComponentBuilder<BeanstalkComponent> {
- /**
- * 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. By default the
- * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
- * with exceptions, that will be logged at WARN or ERROR level and
- * ignored.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default BeanstalkComponentBuilder bridgeErrorHandler(
- boolean bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * Whether the producer should be started lazy (on the first message).
- * By starting lazy you can use this to allow CamelContext and routes to
- * startup in situations where a producer may otherwise fail during
- * starting and cause the route to fail being started. By deferring this
- * startup to be lazy then the startup failure can be handled during
- * routing messages via Camel's routing error handlers. Beware that when
- * the first message is processed then creating and starting the
- * producer may take a little time and prolong the total processing time
- * of the processing.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default BeanstalkComponentBuilder lazyStartProducer(
- boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- /**
- * Whether autowiring is enabled. This is used for automatic autowiring
- * options (the option must be marked as autowired) by looking up in the
- * registry to find if there is a single instance of matching type,
- * which then gets configured on the component. This can be used for
- * automatic configuring JDBC data sources, JMS connection factories,
- * AWS Clients, etc.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: advanced
- *
- * @param autowiredEnabled the value to set
- * @return the dsl builder
- */
- default BeanstalkComponentBuilder autowiredEnabled(
- boolean autowiredEnabled) {
- doSetProperty("autowiredEnabled", autowiredEnabled);
- return this;
- }
- /**
- * Custom ConnectionSettingsFactory. Specify which
- * ConnectionSettingsFactory to use to make connections to Beanstalkd.
- * Especially useful for unit testing without beanstalkd daemon (you can
- * mock ConnectionSettings).
- *
- * The option is a:
- * <code>org.apache.camel.component.beanstalk.ConnectionSettingsFactory</code> type.
- *
- * Group: advanced
- *
- * @param connectionSettingsFactory the value to set
- * @return the dsl builder
- */
- default BeanstalkComponentBuilder connectionSettingsFactory(
- org.apache.camel.component.beanstalk.ConnectionSettingsFactory connectionSettingsFactory) {
- doSetProperty("connectionSettingsFactory", connectionSettingsFactory);
- return this;
- }
- }
-
- class BeanstalkComponentBuilderImpl
- extends
- AbstractComponentBuilder<BeanstalkComponent>
- implements
- BeanstalkComponentBuilder {
- @Override
- protected BeanstalkComponent buildConcreteComponent() {
- return new BeanstalkComponent();
- }
- @Override
- protected boolean setPropertyOnComponent(
- Component component,
- String name,
- Object value) {
- switch (name) {
- case "bridgeErrorHandler": ((BeanstalkComponent) component).setBridgeErrorHandler((boolean) value); return true;
- case "lazyStartProducer": ((BeanstalkComponent) component).setLazyStartProducer((boolean) value); return true;
- case "autowiredEnabled": ((BeanstalkComponent) component).setAutowiredEnabled((boolean) value); return true;
- case "connectionSettingsFactory": ((BeanstalkComponent) component).setConnectionSettingsFactory((org.apache.camel.component.beanstalk.ConnectionSettingsFactory) value); return true;
- default: return false;
- }
- }
- }
-}
\ No newline at end of file
diff --git a/dsl/camel-componentdsl/src/generated/resources/metadata.json b/dsl/camel-componentdsl/src/generated/resources/metadata.json
index c8ee58a..5b9f0b2 100644
--- a/dsl/camel-componentdsl/src/generated/resources/metadata.json
+++ b/dsl/camel-componentdsl/src/generated/resources/metadata.json
@@ -972,28 +972,6 @@
"producerOnly": true,
"lenientProperties": false
},
- "BeanstalkComponentBuilderFactory": {
- "kind": "component",
- "name": "beanstalk",
- "title": "Beanstalk",
- "description": "Retrieve and post-process Beanstalk jobs.",
- "deprecated": true,
- "firstVersion": "2.15.0",
- "label": "messaging",
- "javaType": "org.apache.camel.component.beanstalk.BeanstalkComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-beanstalk",
- "version": "3.17.0-SNAPSHOT",
- "scheme": "beanstalk",
- "extendsScheme": "",
- "syntax": "beanstalk:connectionSettings",
- "async": true,
- "api": false,
- "consumerOnly": false,
- "producerOnly": false,
- "lenientProperties": false
- },
"BonitaComponentBuilderFactory": {
"kind": "component",
"name": "bonita",
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
index f4121da..97ce900 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
@@ -44,7 +44,6 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.AvroEndpointBuilderFactory.AvroBuilders,
org.apache.camel.builder.endpoint.dsl.BeanEndpointBuilderFactory.BeanBuilders,
org.apache.camel.builder.endpoint.dsl.BeanValidatorEndpointBuilderFactory.BeanValidatorBuilders,
- org.apache.camel.builder.endpoint.dsl.BeanstalkEndpointBuilderFactory.BeanstalkBuilders,
org.apache.camel.builder.endpoint.dsl.BlobEndpointBuilderFactory.BlobBuilders,
org.apache.camel.builder.endpoint.dsl.BonitaEndpointBuilderFactory.BonitaBuilders,
org.apache.camel.builder.endpoint.dsl.BoxEndpointBuilderFactory.BoxBuilders,
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
index 304a696c..1ccbcd5 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
@@ -41,7 +41,6 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.AvroEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.BeanEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.BeanValidatorEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.BeanstalkEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.BlobEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.BonitaEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.BoxEndpointBuilderFactory,
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
index 6df2b31..442ebaf 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
@@ -1970,51 +1970,6 @@ public class StaticEndpointBuilders {
return org.apache.camel.builder.endpoint.dsl.BeanEndpointBuilderFactory.endpointBuilder(componentName, path);
}
/**
- * Beanstalk (camel-beanstalk)
- * Retrieve and post-process Beanstalk jobs.
- *
- * Category: messaging
- * Since: 2.15
- * Maven coordinates: org.apache.camel:camel-beanstalk
- *
- * Syntax: <code>beanstalk:connectionSettings</code>
- *
- * Path parameter: connectionSettings
- * Connection settings host:port/tube
- *
- * @param path connectionSettings
- * @return the dsl builder
- */
- @Deprecated
- public static org.apache.camel.builder.endpoint.dsl.BeanstalkEndpointBuilderFactory.BeanstalkEndpointBuilder beanstalk(
- String path) {
- return org.apache.camel.builder.endpoint.dsl.BeanstalkEndpointBuilderFactory.endpointBuilder("beanstalk", path);
- }
- /**
- * Beanstalk (camel-beanstalk)
- * Retrieve and post-process Beanstalk jobs.
- *
- * Category: messaging
- * Since: 2.15
- * Maven coordinates: org.apache.camel:camel-beanstalk
- *
- * Syntax: <code>beanstalk:connectionSettings</code>
- *
- * Path parameter: connectionSettings
- * Connection settings host:port/tube
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path connectionSettings
- * @return the dsl builder
- */
- @Deprecated
- public static org.apache.camel.builder.endpoint.dsl.BeanstalkEndpointBuilderFactory.BeanstalkEndpointBuilder beanstalk(
- String componentName,
- String path) {
- return org.apache.camel.builder.endpoint.dsl.BeanstalkEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
- /**
* Bean Validator (camel-bean-validator)
* Validate the message body using the Java Bean Validation API.
*
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/BeanstalkEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/BeanstalkEndpointBuilderFactory.java
deleted file mode 100644
index e4c9089..0000000
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/BeanstalkEndpointBuilderFactory.java
+++ /dev/null
@@ -1,1380 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.builder.endpoint.dsl;
-
-import java.util.*;
-import java.util.Map;
-import java.util.concurrent.*;
-import java.util.function.*;
-import java.util.stream.*;
-import javax.annotation.Generated;
-import org.apache.camel.builder.EndpointConsumerBuilder;
-import org.apache.camel.builder.EndpointProducerBuilder;
-import org.apache.camel.builder.endpoint.AbstractEndpointBuilder;
-
-/**
- * Retrieve and post-process Beanstalk jobs.
- *
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
-public interface BeanstalkEndpointBuilderFactory {
-
-
- /**
- * Builder for endpoint consumers for the Beanstalk component.
- */
- public interface BeanstalkEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default AdvancedBeanstalkEndpointConsumerBuilder advanced() {
- return (AdvancedBeanstalkEndpointConsumerBuilder) this;
- }
- /**
- * put means to put the job into Beanstalk. Job body is specified in the
- * Camel message body. Job ID will be returned in beanstalk.jobId
- * message header. delete, release, touch or bury expect Job ID in the
- * message header beanstalk.jobId. Result of the operation is returned
- * in beanstalk.result message header kick expects the number of jobs to
- * kick in the message body and returns the number of jobs actually
- * kicked out in the message header beanstalk.result.
- *
- * The option is a:
- * <code>org.apache.camel.component.beanstalk.BeanstalkCommand</code> type.
- *
- * Group: common
- *
- * @param command the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder command(
- org.apache.camel.component.beanstalk.BeanstalkCommand command) {
- doSetProperty("command", command);
- return this;
- }
- /**
- * put means to put the job into Beanstalk. Job body is specified in the
- * Camel message body. Job ID will be returned in beanstalk.jobId
- * message header. delete, release, touch or bury expect Job ID in the
- * message header beanstalk.jobId. Result of the operation is returned
- * in beanstalk.result message header kick expects the number of jobs to
- * kick in the message body and returns the number of jobs actually
- * kicked out in the message header beanstalk.result.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.beanstalk.BeanstalkCommand</code> type.
- *
- * Group: common
- *
- * @param command the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder command(String command) {
- doSetProperty("command", command);
- return this;
- }
- /**
- * Job delay in seconds.
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 0
- * Group: common
- *
- * @param jobDelay the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder jobDelay(int jobDelay) {
- doSetProperty("jobDelay", jobDelay);
- return this;
- }
- /**
- * Job delay in seconds.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Default: 0
- * Group: common
- *
- * @param jobDelay the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder jobDelay(String jobDelay) {
- doSetProperty("jobDelay", jobDelay);
- return this;
- }
- /**
- * Job priority. (0 is the highest, see Beanstalk protocol).
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 1000
- * Group: common
- *
- * @param jobPriority the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder jobPriority(long jobPriority) {
- doSetProperty("jobPriority", jobPriority);
- return this;
- }
- /**
- * Job priority. (0 is the highest, see Beanstalk protocol).
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Default: 1000
- * Group: common
- *
- * @param jobPriority the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder jobPriority(String jobPriority) {
- doSetProperty("jobPriority", jobPriority);
- return this;
- }
- /**
- * Job time to run in seconds. (when 0, the beanstalkd daemon raises it
- * to 1 automatically, see Beanstalk protocol).
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 60
- * Group: common
- *
- * @param jobTimeToRun the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder jobTimeToRun(int jobTimeToRun) {
- doSetProperty("jobTimeToRun", jobTimeToRun);
- return this;
- }
- /**
- * Job time to run in seconds. (when 0, the beanstalkd daemon raises it
- * to 1 automatically, see Beanstalk protocol).
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Default: 60
- * Group: common
- *
- * @param jobTimeToRun the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder jobTimeToRun(
- String jobTimeToRun) {
- doSetProperty("jobTimeToRun", jobTimeToRun);
- return this;
- }
- /**
- * Whether to wait for job to complete before ack the job from
- * beanstalk.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: consumer
- *
- * @param awaitJob the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder awaitJob(boolean awaitJob) {
- doSetProperty("awaitJob", awaitJob);
- return this;
- }
- /**
- * Whether to wait for job to complete before ack the job from
- * beanstalk.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: consumer
- *
- * @param awaitJob the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder awaitJob(String awaitJob) {
- doSetProperty("awaitJob", awaitJob);
- return this;
- }
- /**
- * 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. By default the
- * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
- * with exceptions, that will be logged at WARN or ERROR level and
- * ignored.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder bridgeErrorHandler(
- boolean bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * 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. By default the
- * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
- * with exceptions, that will be logged at WARN or ERROR level and
- * ignored.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: consumer
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder bridgeErrorHandler(
- String bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * Command to use when processing failed.
- *
- * The option is a:
- * <code>org.apache.camel.component.beanstalk.BeanstalkCommand</code> type.
- *
- * Group: consumer
- *
- * @param onFailure the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder onFailure(
- org.apache.camel.component.beanstalk.BeanstalkCommand onFailure) {
- doSetProperty("onFailure", onFailure);
- return this;
- }
- /**
- * Command to use when processing failed.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.beanstalk.BeanstalkCommand</code> type.
- *
- * Group: consumer
- *
- * @param onFailure the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder onFailure(String onFailure) {
- doSetProperty("onFailure", onFailure);
- return this;
- }
- /**
- * If the polling consumer did not poll any files, you can enable this
- * option to send an empty message (no body) instead.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- *
- * @param sendEmptyMessageWhenIdle the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder sendEmptyMessageWhenIdle(
- boolean sendEmptyMessageWhenIdle) {
- doSetProperty("sendEmptyMessageWhenIdle", sendEmptyMessageWhenIdle);
- return this;
- }
- /**
- * If the polling consumer did not poll any files, you can enable this
- * option to send an empty message (no body) instead.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: consumer
- *
- * @param sendEmptyMessageWhenIdle the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder sendEmptyMessageWhenIdle(
- String sendEmptyMessageWhenIdle) {
- doSetProperty("sendEmptyMessageWhenIdle", sendEmptyMessageWhenIdle);
- return this;
- }
- /**
- * Whether to use blockIO.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: consumer
- *
- * @param useBlockIO the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder useBlockIO(boolean useBlockIO) {
- doSetProperty("useBlockIO", useBlockIO);
- return this;
- }
- /**
- * Whether to use blockIO.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: consumer
- *
- * @param useBlockIO the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder useBlockIO(String useBlockIO) {
- doSetProperty("useBlockIO", useBlockIO);
- return this;
- }
- /**
- * The number of subsequent error polls (failed due some error) that
- * should happen before the backoffMultipler should kick-in.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: scheduler
- *
- * @param backoffErrorThreshold the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder backoffErrorThreshold(
- int backoffErrorThreshold) {
- doSetProperty("backoffErrorThreshold", backoffErrorThreshold);
- return this;
- }
- /**
- * The number of subsequent error polls (failed due some error) that
- * should happen before the backoffMultipler should kick-in.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: scheduler
- *
- * @param backoffErrorThreshold the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder backoffErrorThreshold(
- String backoffErrorThreshold) {
- doSetProperty("backoffErrorThreshold", backoffErrorThreshold);
- return this;
- }
- /**
- * The number of subsequent idle polls that should happen before the
- * backoffMultipler should kick-in.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: scheduler
- *
- * @param backoffIdleThreshold the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder backoffIdleThreshold(
- int backoffIdleThreshold) {
- doSetProperty("backoffIdleThreshold", backoffIdleThreshold);
- return this;
- }
- /**
- * The number of subsequent idle polls that should happen before the
- * backoffMultipler should kick-in.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: scheduler
- *
- * @param backoffIdleThreshold the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder backoffIdleThreshold(
- String backoffIdleThreshold) {
- doSetProperty("backoffIdleThreshold", backoffIdleThreshold);
- return this;
- }
- /**
- * To let the scheduled polling consumer backoff if there has been a
- * number of subsequent idles/errors in a row. The multiplier is then
- * the number of polls that will be skipped before the next actual
- * attempt is happening again. When this option is in use then
- * backoffIdleThreshold and/or backoffErrorThreshold must also be
- * configured.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: scheduler
- *
- * @param backoffMultiplier the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder backoffMultiplier(
- int backoffMultiplier) {
- doSetProperty("backoffMultiplier", backoffMultiplier);
- return this;
- }
- /**
- * To let the scheduled polling consumer backoff if there has been a
- * number of subsequent idles/errors in a row. The multiplier is then
- * the number of polls that will be skipped before the next actual
- * attempt is happening again. When this option is in use then
- * backoffIdleThreshold and/or backoffErrorThreshold must also be
- * configured.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: scheduler
- *
- * @param backoffMultiplier the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder backoffMultiplier(
- String backoffMultiplier) {
- doSetProperty("backoffMultiplier", backoffMultiplier);
- return this;
- }
- /**
- * Milliseconds before the next poll.
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 500
- * Group: scheduler
- *
- * @param delay the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder delay(long delay) {
- doSetProperty("delay", delay);
- return this;
- }
- /**
- * Milliseconds before the next poll.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Default: 500
- * Group: scheduler
- *
- * @param delay the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder delay(String delay) {
- doSetProperty("delay", delay);
- return this;
- }
- /**
- * If greedy is enabled, then the ScheduledPollConsumer will run
- * immediately again, if the previous run polled 1 or more messages.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: scheduler
- *
- * @param greedy the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder greedy(boolean greedy) {
- doSetProperty("greedy", greedy);
- return this;
- }
- /**
- * If greedy is enabled, then the ScheduledPollConsumer will run
- * immediately again, if the previous run polled 1 or more messages.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: scheduler
- *
- * @param greedy the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder greedy(String greedy) {
- doSetProperty("greedy", greedy);
- return this;
- }
- /**
- * Milliseconds before the first poll starts.
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 1000
- * Group: scheduler
- *
- * @param initialDelay the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder initialDelay(long initialDelay) {
- doSetProperty("initialDelay", initialDelay);
- return this;
- }
- /**
- * Milliseconds before the first poll starts.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Default: 1000
- * Group: scheduler
- *
- * @param initialDelay the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder initialDelay(
- String initialDelay) {
- doSetProperty("initialDelay", initialDelay);
- return this;
- }
- /**
- * Specifies a maximum limit of number of fires. So if you set it to 1,
- * the scheduler will only fire once. If you set it to 5, it will only
- * fire five times. A value of zero or negative means fire forever.
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 0
- * Group: scheduler
- *
- * @param repeatCount the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder repeatCount(long repeatCount) {
- doSetProperty("repeatCount", repeatCount);
- return this;
- }
- /**
- * Specifies a maximum limit of number of fires. So if you set it to 1,
- * the scheduler will only fire once. If you set it to 5, it will only
- * fire five times. A value of zero or negative means fire forever.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Default: 0
- * Group: scheduler
- *
- * @param repeatCount the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder repeatCount(String repeatCount) {
- doSetProperty("repeatCount", repeatCount);
- return this;
- }
- /**
- * The consumer logs a start/complete log line when it polls. This
- * option allows you to configure the logging level for that.
- *
- * The option is a:
- * <code>org.apache.camel.LoggingLevel</code> type.
- *
- * Default: TRACE
- * Group: scheduler
- *
- * @param runLoggingLevel the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder runLoggingLevel(
- org.apache.camel.LoggingLevel runLoggingLevel) {
- doSetProperty("runLoggingLevel", runLoggingLevel);
- return this;
- }
- /**
- * The consumer logs a start/complete log line when it polls. This
- * option allows you to configure the logging level for that.
- *
- * The option will be converted to a
- * <code>org.apache.camel.LoggingLevel</code> type.
- *
- * Default: TRACE
- * Group: scheduler
- *
- * @param runLoggingLevel the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder runLoggingLevel(
- String runLoggingLevel) {
- doSetProperty("runLoggingLevel", runLoggingLevel);
- return this;
- }
- /**
- * Allows for configuring a custom/shared thread pool to use for the
- * consumer. By default each consumer has its own single threaded thread
- * pool.
- *
- * The option is a:
- * <code>java.util.concurrent.ScheduledExecutorService</code> type.
- *
- * Group: scheduler
- *
- * @param scheduledExecutorService the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder scheduledExecutorService(
- ScheduledExecutorService scheduledExecutorService) {
- doSetProperty("scheduledExecutorService", scheduledExecutorService);
- return this;
- }
- /**
- * Allows for configuring a custom/shared thread pool to use for the
- * consumer. By default each consumer has its own single threaded thread
- * pool.
- *
- * The option will be converted to a
- * <code>java.util.concurrent.ScheduledExecutorService</code> type.
- *
- * Group: scheduler
- *
- * @param scheduledExecutorService the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder scheduledExecutorService(
- String scheduledExecutorService) {
- doSetProperty("scheduledExecutorService", scheduledExecutorService);
- return this;
- }
- /**
- * To use a cron scheduler from either camel-spring or camel-quartz
- * component. Use value spring or quartz for built in scheduler.
- *
- * The option is a: <code>java.lang.Object</code> type.
- *
- * Default: none
- * Group: scheduler
- *
- * @param scheduler the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder scheduler(Object scheduler) {
- doSetProperty("scheduler", scheduler);
- return this;
- }
- /**
- * To use a cron scheduler from either camel-spring or camel-quartz
- * component. Use value spring or quartz for built in scheduler.
- *
- * The option will be converted to a
- * <code>java.lang.Object</code> type.
- *
- * Default: none
- * Group: scheduler
- *
- * @param scheduler the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder scheduler(String scheduler) {
- doSetProperty("scheduler", scheduler);
- return this;
- }
- /**
- * To configure additional properties when using a custom scheduler or
- * any of the Quartz, Spring based scheduler.
- *
- * The option is a: <code>java.util.Map&lt;java.lang.String,
- * java.lang.Object&gt;</code> type.
- * The option is multivalued, and you can use the
- * schedulerProperties(String, Object) method to add a value (call the
- * method multiple times to set more values).
- *
- * Group: scheduler
- *
- * @param key the option key
- * @param value the option value
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder schedulerProperties(
- String key,
- Object value) {
- doSetMultiValueProperty("schedulerProperties", "scheduler." + key, value);
- return this;
- }
- /**
- * To configure additional properties when using a custom scheduler or
- * any of the Quartz, Spring based scheduler.
- *
- * The option is a: <code>java.util.Map&lt;java.lang.String,
- * java.lang.Object&gt;</code> type.
- * The option is multivalued, and you can use the
- * schedulerProperties(String, Object) method to add a value (call the
- * method multiple times to set more values).
- *
- * Group: scheduler
- *
- * @param values the values
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder schedulerProperties(Map values) {
- doSetMultiValueProperties("schedulerProperties", "scheduler.", values);
- return this;
- }
- /**
- * Whether the scheduler should be auto started.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: scheduler
- *
- * @param startScheduler the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder startScheduler(
- boolean startScheduler) {
- doSetProperty("startScheduler", startScheduler);
- return this;
- }
- /**
- * Whether the scheduler should be auto started.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: scheduler
- *
- * @param startScheduler the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder startScheduler(
- String startScheduler) {
- doSetProperty("startScheduler", startScheduler);
- return this;
- }
- /**
- * Time unit for initialDelay and delay options.
- *
- * The option is a:
- * <code>java.util.concurrent.TimeUnit</code> type.
- *
- * Default: MILLISECONDS
- * Group: scheduler
- *
- * @param timeUnit the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder timeUnit(TimeUnit timeUnit) {
- doSetProperty("timeUnit", timeUnit);
- return this;
- }
- /**
- * Time unit for initialDelay and delay options.
- *
- * The option will be converted to a
- * <code>java.util.concurrent.TimeUnit</code> type.
- *
- * Default: MILLISECONDS
- * Group: scheduler
- *
- * @param timeUnit the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder timeUnit(String timeUnit) {
- doSetProperty("timeUnit", timeUnit);
- return this;
- }
- /**
- * Controls if fixed delay or fixed rate is used. See
- * ScheduledExecutorService in JDK for details.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: scheduler
- *
- * @param useFixedDelay the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder useFixedDelay(
- boolean useFixedDelay) {
- doSetProperty("useFixedDelay", useFixedDelay);
- return this;
- }
- /**
- * Controls if fixed delay or fixed rate is used. See
- * ScheduledExecutorService in JDK for details.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: scheduler
- *
- * @param useFixedDelay the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointConsumerBuilder useFixedDelay(
- String useFixedDelay) {
- doSetProperty("useFixedDelay", useFixedDelay);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint consumers for the Beanstalk component.
- */
- public interface AdvancedBeanstalkEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default BeanstalkEndpointConsumerBuilder basic() {
- return (BeanstalkEndpointConsumerBuilder) this;
- }
- /**
- * To let the consumer use a custom ExceptionHandler. Notice if the
- * option bridgeErrorHandler is enabled then this option is not in use.
- * By default the consumer will deal with exceptions, that will be
- * logged at WARN or ERROR level and ignored.
- *
- * The option is a:
- * <code>org.apache.camel.spi.ExceptionHandler</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param exceptionHandler the value to set
- * @return the dsl builder
- */
- default AdvancedBeanstalkEndpointConsumerBuilder exceptionHandler(
- org.apache.camel.spi.ExceptionHandler exceptionHandler) {
- doSetProperty("exceptionHandler", exceptionHandler);
- return this;
- }
- /**
- * To let the consumer use a custom ExceptionHandler. Notice if the
- * option bridgeErrorHandler is enabled then this option is not in use.
- * By default the consumer will deal with exceptions, that will be
- * logged at WARN or ERROR level and ignored.
- *
- * The option will be converted to a
- * <code>org.apache.camel.spi.ExceptionHandler</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param exceptionHandler the value to set
- * @return the dsl builder
- */
- default AdvancedBeanstalkEndpointConsumerBuilder exceptionHandler(
- String exceptionHandler) {
- doSetProperty("exceptionHandler", exceptionHandler);
- return this;
- }
- /**
- * Sets the exchange pattern when the consumer creates an exchange.
- *
- * The option is a:
- * <code>org.apache.camel.ExchangePattern</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param exchangePattern the value to set
- * @return the dsl builder
- */
- default AdvancedBeanstalkEndpointConsumerBuilder exchangePattern(
- org.apache.camel.ExchangePattern exchangePattern) {
- doSetProperty("exchangePattern", exchangePattern);
- return this;
- }
- /**
- * Sets the exchange pattern when the consumer creates an exchange.
- *
- * The option will be converted to a
- * <code>org.apache.camel.ExchangePattern</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param exchangePattern the value to set
- * @return the dsl builder
- */
- default AdvancedBeanstalkEndpointConsumerBuilder exchangePattern(
- String exchangePattern) {
- doSetProperty("exchangePattern", exchangePattern);
- return this;
- }
- /**
- * A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing
- * you to provide your custom implementation to control error handling
- * usually occurred during the poll operation before an Exchange have
- * been created and being routed in Camel.
- *
- * The option is a:
- * <code>org.apache.camel.spi.PollingConsumerPollStrategy</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param pollStrategy the value to set
- * @return the dsl builder
- */
- default AdvancedBeanstalkEndpointConsumerBuilder pollStrategy(
- org.apache.camel.spi.PollingConsumerPollStrategy pollStrategy) {
- doSetProperty("pollStrategy", pollStrategy);
- return this;
- }
- /**
- * A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing
- * you to provide your custom implementation to control error handling
- * usually occurred during the poll operation before an Exchange have
- * been created and being routed in Camel.
- *
- * The option will be converted to a
- * <code>org.apache.camel.spi.PollingConsumerPollStrategy</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param pollStrategy the value to set
- * @return the dsl builder
- */
- default AdvancedBeanstalkEndpointConsumerBuilder pollStrategy(
- String pollStrategy) {
- doSetProperty("pollStrategy", pollStrategy);
- return this;
- }
- }
-
- /**
- * Builder for endpoint producers for the Beanstalk component.
- */
- public interface BeanstalkEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default AdvancedBeanstalkEndpointProducerBuilder advanced() {
- return (AdvancedBeanstalkEndpointProducerBuilder) this;
- }
- /**
- * put means to put the job into Beanstalk. Job body is specified in the
- * Camel message body. Job ID will be returned in beanstalk.jobId
- * message header. delete, release, touch or bury expect Job ID in the
- * message header beanstalk.jobId. Result of the operation is returned
- * in beanstalk.result message header kick expects the number of jobs to
- * kick in the message body and returns the number of jobs actually
- * kicked out in the message header beanstalk.result.
- *
- * The option is a:
- * <code>org.apache.camel.component.beanstalk.BeanstalkCommand</code> type.
- *
- * Group: common
- *
- * @param command the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointProducerBuilder command(
- org.apache.camel.component.beanstalk.BeanstalkCommand command) {
- doSetProperty("command", command);
- return this;
- }
- /**
- * put means to put the job into Beanstalk. Job body is specified in the
- * Camel message body. Job ID will be returned in beanstalk.jobId
- * message header. delete, release, touch or bury expect Job ID in the
- * message header beanstalk.jobId. Result of the operation is returned
- * in beanstalk.result message header kick expects the number of jobs to
- * kick in the message body and returns the number of jobs actually
- * kicked out in the message header beanstalk.result.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.beanstalk.BeanstalkCommand</code> type.
- *
- * Group: common
- *
- * @param command the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointProducerBuilder command(String command) {
- doSetProperty("command", command);
- return this;
- }
- /**
- * Job delay in seconds.
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 0
- * Group: common
- *
- * @param jobDelay the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointProducerBuilder jobDelay(int jobDelay) {
- doSetProperty("jobDelay", jobDelay);
- return this;
- }
- /**
- * Job delay in seconds.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Default: 0
- * Group: common
- *
- * @param jobDelay the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointProducerBuilder jobDelay(String jobDelay) {
- doSetProperty("jobDelay", jobDelay);
- return this;
- }
- /**
- * Job priority. (0 is the highest, see Beanstalk protocol).
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 1000
- * Group: common
- *
- * @param jobPriority the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointProducerBuilder jobPriority(long jobPriority) {
- doSetProperty("jobPriority", jobPriority);
- return this;
- }
- /**
- * Job priority. (0 is the highest, see Beanstalk protocol).
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Default: 1000
- * Group: common
- *
- * @param jobPriority the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointProducerBuilder jobPriority(String jobPriority) {
- doSetProperty("jobPriority", jobPriority);
- return this;
- }
- /**
- * Job time to run in seconds. (when 0, the beanstalkd daemon raises it
- * to 1 automatically, see Beanstalk protocol).
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 60
- * Group: common
- *
- * @param jobTimeToRun the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointProducerBuilder jobTimeToRun(int jobTimeToRun) {
- doSetProperty("jobTimeToRun", jobTimeToRun);
- return this;
- }
- /**
- * Job time to run in seconds. (when 0, the beanstalkd daemon raises it
- * to 1 automatically, see Beanstalk protocol).
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Default: 60
- * Group: common
- *
- * @param jobTimeToRun the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointProducerBuilder jobTimeToRun(
- String jobTimeToRun) {
- doSetProperty("jobTimeToRun", jobTimeToRun);
- return this;
- }
- /**
- * Whether the producer should be started lazy (on the first message).
- * By starting lazy you can use this to allow CamelContext and routes to
- * startup in situations where a producer may otherwise fail during
- * starting and cause the route to fail being started. By deferring this
- * startup to be lazy then the startup failure can be handled during
- * routing messages via Camel's routing error handlers. Beware that when
- * the first message is processed then creating and starting the
- * producer may take a little time and prolong the total processing time
- * of the processing.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointProducerBuilder lazyStartProducer(
- boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- /**
- * Whether the producer should be started lazy (on the first message).
- * By starting lazy you can use this to allow CamelContext and routes to
- * startup in situations where a producer may otherwise fail during
- * starting and cause the route to fail being started. By deferring this
- * startup to be lazy then the startup failure can be handled during
- * routing messages via Camel's routing error handlers. Beware that when
- * the first message is processed then creating and starting the
- * producer may take a little time and prolong the total processing time
- * of the processing.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: producer
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointProducerBuilder lazyStartProducer(
- String lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint producers for the Beanstalk component.
- */
- public interface AdvancedBeanstalkEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default BeanstalkEndpointProducerBuilder basic() {
- return (BeanstalkEndpointProducerBuilder) this;
- }
- }
-
- /**
- * Builder for endpoint for the Beanstalk component.
- */
- public interface BeanstalkEndpointBuilder
- extends
- BeanstalkEndpointConsumerBuilder,
- BeanstalkEndpointProducerBuilder {
- default AdvancedBeanstalkEndpointBuilder advanced() {
- return (AdvancedBeanstalkEndpointBuilder) this;
- }
- /**
- * put means to put the job into Beanstalk. Job body is specified in the
- * Camel message body. Job ID will be returned in beanstalk.jobId
- * message header. delete, release, touch or bury expect Job ID in the
- * message header beanstalk.jobId. Result of the operation is returned
- * in beanstalk.result message header kick expects the number of jobs to
- * kick in the message body and returns the number of jobs actually
- * kicked out in the message header beanstalk.result.
- *
- * The option is a:
- * <code>org.apache.camel.component.beanstalk.BeanstalkCommand</code> type.
- *
- * Group: common
- *
- * @param command the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointBuilder command(
- org.apache.camel.component.beanstalk.BeanstalkCommand command) {
- doSetProperty("command", command);
- return this;
- }
- /**
- * put means to put the job into Beanstalk. Job body is specified in the
- * Camel message body. Job ID will be returned in beanstalk.jobId
- * message header. delete, release, touch or bury expect Job ID in the
- * message header beanstalk.jobId. Result of the operation is returned
- * in beanstalk.result message header kick expects the number of jobs to
- * kick in the message body and returns the number of jobs actually
- * kicked out in the message header beanstalk.result.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.beanstalk.BeanstalkCommand</code> type.
- *
- * Group: common
- *
- * @param command the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointBuilder command(String command) {
- doSetProperty("command", command);
- return this;
- }
- /**
- * Job delay in seconds.
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 0
- * Group: common
- *
- * @param jobDelay the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointBuilder jobDelay(int jobDelay) {
- doSetProperty("jobDelay", jobDelay);
- return this;
- }
- /**
- * Job delay in seconds.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Default: 0
- * Group: common
- *
- * @param jobDelay the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointBuilder jobDelay(String jobDelay) {
- doSetProperty("jobDelay", jobDelay);
- return this;
- }
- /**
- * Job priority. (0 is the highest, see Beanstalk protocol).
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 1000
- * Group: common
- *
- * @param jobPriority the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointBuilder jobPriority(long jobPriority) {
- doSetProperty("jobPriority", jobPriority);
- return this;
- }
- /**
- * Job priority. (0 is the highest, see Beanstalk protocol).
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Default: 1000
- * Group: common
- *
- * @param jobPriority the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointBuilder jobPriority(String jobPriority) {
- doSetProperty("jobPriority", jobPriority);
- return this;
- }
- /**
- * Job time to run in seconds. (when 0, the beanstalkd daemon raises it
- * to 1 automatically, see Beanstalk protocol).
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 60
- * Group: common
- *
- * @param jobTimeToRun the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointBuilder jobTimeToRun(int jobTimeToRun) {
- doSetProperty("jobTimeToRun", jobTimeToRun);
- return this;
- }
- /**
- * Job time to run in seconds. (when 0, the beanstalkd daemon raises it
- * to 1 automatically, see Beanstalk protocol).
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Default: 60
- * Group: common
- *
- * @param jobTimeToRun the value to set
- * @return the dsl builder
- */
- default BeanstalkEndpointBuilder jobTimeToRun(String jobTimeToRun) {
- doSetProperty("jobTimeToRun", jobTimeToRun);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint for the Beanstalk component.
- */
- public interface AdvancedBeanstalkEndpointBuilder
- extends
- AdvancedBeanstalkEndpointConsumerBuilder,
- AdvancedBeanstalkEndpointProducerBuilder {
- default BeanstalkEndpointBuilder basic() {
- return (BeanstalkEndpointBuilder) this;
- }
- }
-
- public interface BeanstalkBuilders {
- /**
- * Beanstalk (camel-beanstalk)
- * Retrieve and post-process Beanstalk jobs.
- *
- * Category: messaging
- * Since: 2.15
- * Maven coordinates: org.apache.camel:camel-beanstalk
- *
- * Syntax: <code>beanstalk:connectionSettings</code>
- *
- * Path parameter: connectionSettings
- * Connection settings host:port/tube
- *
- * @param path connectionSettings
- * @return the dsl builder
- */
- @Deprecated
- default BeanstalkEndpointBuilder beanstalk(String path) {
- return BeanstalkEndpointBuilderFactory.endpointBuilder("beanstalk", path);
- }
- /**
- * Beanstalk (camel-beanstalk)
- * Retrieve and post-process Beanstalk jobs.
- *
- * Category: messaging
- * Since: 2.15
- * Maven coordinates: org.apache.camel:camel-beanstalk
- *
- * Syntax: <code>beanstalk:connectionSettings</code>
- *
- * Path parameter: connectionSettings
- * Connection settings host:port/tube
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path connectionSettings
- * @return the dsl builder
- */
- @Deprecated
- default BeanstalkEndpointBuilder beanstalk(
- String componentName,
- String path) {
- return BeanstalkEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
- }
- @Deprecated
- static BeanstalkEndpointBuilder endpointBuilder(
- String componentName,
- String path) {
- class BeanstalkEndpointBuilderImpl extends AbstractEndpointBuilder implements BeanstalkEndpointBuilder, AdvancedBeanstalkEndpointBuilder {
- public BeanstalkEndpointBuilderImpl(String path) {
- super(componentName, path);
- }
- }
- return new BeanstalkEndpointBuilderImpl(path);
- }
-}
\ No newline at end of file
diff --git a/parent/pom.xml b/parent/pom.xml
index 0a0ffce..cbd3825 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -1057,11 +1057,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-beanstalk</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-bindy</artifactId>
<version>${project.version}</version>
</dependency>