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 <[email protected]> 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>
