This is an automated email from the ASF dual-hosted git repository.
apupier pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 6b6f64bfc5f3 Removal of Guava EventBus component
6b6f64bfc5f3 is described below
commit 6b6f64bfc5f3e0044295386391ed8d324d257272
Author: Aurélien Pupier <[email protected]>
AuthorDate: Mon May 4 17:19:58 2026 +0200
Removal of Guava EventBus component
it was deprecated since Camel 4.6
Signed-off-by: Aurélien Pupier <[email protected]>
---
bom/camel-bom/pom.xml | 5 -
catalog/camel-allcomponents/pom.xml | 5 -
.../org/apache/camel/catalog/components.properties | 1 -
.../camel/catalog/components/guava-eventbus.json | 42 --
components/camel-guava-eventbus/pom.xml | 53 --
.../eventbus/GuavaEventBusComponentConfigurer.java | 84 ----
.../eventbus/GuavaEventBusEndpointConfigurer.java | 92 ----
.../eventbus/GuavaEventBusEndpointUriFactory.java | 76 ---
.../component/guava/eventbus/guava-eventbus.json | 42 --
.../services/org/apache/camel/component.properties | 7 -
.../org/apache/camel/component/guava-eventbus | 2 -
.../camel/configurer/guava-eventbus-component | 2 -
.../camel/configurer/guava-eventbus-endpoint | 2 -
.../camel/urifactory/guava-eventbus-endpoint | 2 -
.../src/main/docs/guava-eventbus-component.adoc | 188 -------
.../guava/eventbus/CamelEventHandler.java | 71 ---
.../guava/eventbus/FilteringCamelEventHandler.java | 53 --
.../guava/eventbus/GuavaEventBusComponent.java | 70 ---
.../guava/eventbus/GuavaEventBusConsumer.java | 100 ----
.../guava/eventbus/GuavaEventBusEndpoint.java | 133 -----
.../guava/eventbus/GuavaEventBusProducer.java | 52 --
.../component/guava/eventbus/CustomListener.java | 26 -
.../guava/eventbus/CustomMultiEventListener.java | 31 --
.../guava/eventbus/DeadEventListener.java | 27 -
.../guava/eventbus/GuavaEventBusComponentTest.java | 67 ---
.../GuavaEventBusConsumerConfigurationTest.java | 59 ---
.../guava/eventbus/GuavaEventBusConsumerTest.java | 133 -----
.../GuavaEventBusConsumingDeadEventsTest.java | 67 ---
.../guava/eventbus/GuavaEventBusProducerTest.java | 63 ---
.../component/guava/eventbus/MessageWrapper.java | 31 --
.../src/test/resources/log4j2.properties | 28 --
components/pom.xml | 1 -
.../org/apache/camel/main/components.properties | 1 -
coverage/pom.xml | 5 -
.../modules/ROOT/examples/json/guava-eventbus.json | 1 -
docs/components/modules/ROOT/nav.adoc | 1 -
.../ROOT/pages/guava-eventbus-component.adoc | 1 -
.../ROOT/pages/camel-4x-upgrade-guide-4_21.adoc | 4 +
.../component/ComponentsBuilderFactory.java | 13 -
.../dsl/GuavaEventbusComponentBuilderFactory.java | 187 -------
.../builder/endpoint/EndpointBuilderFactory.java | 1 -
.../camel/builder/endpoint/EndpointBuilders.java | 1 -
.../builder/endpoint/StaticEndpointBuilders.java | 42 --
.../dsl/GuavaEventBusEndpointBuilderFactory.java | 557 ---------------------
.../camel-component-known-dependencies.properties | 1 -
parent/pom.xml | 5 -
46 files changed, 4 insertions(+), 2431 deletions(-)
diff --git a/bom/camel-bom/pom.xml b/bom/camel-bom/pom.xml
index 3710c8d58aab..56716b24bb75 100644
--- a/bom/camel-bom/pom.xml
+++ b/bom/camel-bom/pom.xml
@@ -1037,11 +1037,6 @@
<artifactId>camel-gson</artifactId>
<version>4.21.0-SNAPSHOT</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-guava-eventbus</artifactId>
- <version>4.21.0-SNAPSHOT</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-hashicorp-vault</artifactId>
diff --git a/catalog/camel-allcomponents/pom.xml
b/catalog/camel-allcomponents/pom.xml
index 06619e1ecebe..dc8533b11d62 100644
--- a/catalog/camel-allcomponents/pom.xml
+++ b/catalog/camel-allcomponents/pom.xml
@@ -902,11 +902,6 @@
<artifactId>camel-gson</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-guava-eventbus</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-hashicorp-vault</artifactId>
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
index 75a89701c5e4..593e5fe612b4 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
@@ -147,7 +147,6 @@ google-vision
grape
graphql
grpc
-guava-eventbus
hashicorp-vault
hazelcast-atomicvalue
hazelcast-instance
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/guava-eventbus.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/guava-eventbus.json
deleted file mode 100644
index 96be6aa01813..000000000000
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/guava-eventbus.json
+++ /dev/null
@@ -1,42 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "guava-eventbus",
- "title": "Guava EventBus",
- "description": "Send and receive messages to\/from Guava EventBus.",
- "deprecated": true,
- "firstVersion": "2.10.0",
- "label": "messaging",
- "javaType":
"org.apache.camel.component.guava.eventbus.GuavaEventBusComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-guava-eventbus",
- "version": "4.21.0-SNAPSHOT",
- "scheme": "guava-eventbus",
- "extendsScheme": "",
- "syntax": "guava-eventbus:eventBusRef",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": false,
- "lenientProperties": false,
- "browsable": false,
- "remote": false
- },
- "componentProperties": {
- "eventBus": { "index": 0, "kind": "property", "displayName": "Event Bus",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "com.google.common.eventbus.EventBus", "deprecated": false,
"autowired": false, "secret": false, "description": "To use the given Guava
EventBus instance" },
- "bridgeErrorHandler": { "index": 1, "kind": "property", "displayName":
"Bridge Error Handler", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Allows for bridging the consumer to the Camel routing Error Handler, which
mean any exceptions (if possible) occurred while the Camel consumer is trying
to pickup incoming messages, or the like [...]
- "listenerInterface": { "index": 2, "kind": "property", "displayName":
"Listener Interface", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.Class<java.lang.Object>",
"deprecated": false, "autowired": false, "secret": false, "description": "The
interface with method(s) marked with the Subscribe annotation. Dynamic proxy
will be created over the interface so it could be registered as the EventBus
listener. Particularly useful when c [...]
- "lazyStartProducer": { "index": 3, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"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 [...]
- "autowiredEnabled": { "index": 4, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"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 t [...]
- },
- "properties": {
- "eventBusRef": { "index": 0, "kind": "path", "displayName": "Event Bus
Ref", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To lookup the Guava EventBus from the registry
with the given name" },
- "eventClass": { "index": 1, "kind": "parameter", "displayName": "Event
Class", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.Class<java.lang.Object>", "deprecated": false,
"autowired": false, "secret": false, "description": "If used on the consumer
side of the route, will filter events received from the EventBus to the
instances of the class and superclasses of eventClass. Null value of this
option is equal to setting it to the java.lang. [...]
- "listenerInterface": { "index": 2, "kind": "parameter", "displayName":
"Listener Interface", "group": "common", "label": "", "required": false,
"type": "string", "javaType": "java.lang.Class<java.lang.Object>",
"deprecated": false, "autowired": false, "secret": false, "description": "The
interface with method(s) marked with the Subscribe annotation. Dynamic proxy
will be created over the interface so it could be registered as the EventBus
listener. Particularly useful when creating m [...]
- "bridgeErrorHandler": { "index": 3, "kind": "parameter", "displayName":
"Bridge Error Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions (if possible) occurred
while the Camel consumer is trying to pickup incoming [...]
- "exceptionHandler": { "index": 4, "kind": "parameter", "displayName":
"Exception Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By def [...]
- "exchangePattern": { "index": 5, "kind": "parameter", "displayName":
"Exchange Pattern", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "enum", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ],
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the exchange pattern when the consumer creates an exchange." },
- "lazyStartProducer": { "index": 6, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "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 produc [...]
- }
-}
diff --git a/components/camel-guava-eventbus/pom.xml
b/components/camel-guava-eventbus/pom.xml
deleted file mode 100644
index 301f38b9b0c6..000000000000
--- a/components/camel-guava-eventbus/pom.xml
+++ /dev/null
@@ -1,53 +0,0 @@
-<?xml version="1.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.
-
--->
-<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.camel</groupId>
- <artifactId>components</artifactId>
- <version>4.21.0-SNAPSHOT</version>
- </parent>
-
- <artifactId>camel-guava-eventbus</artifactId>
- <packaging>jar</packaging>
- <name>Camel :: Guava-EventBus (deprecated)</name>
- <description>Camel Guava EventBus support</description>
-
- <properties>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-support</artifactId>
- </dependency>
- <dependency>
- <groupId>com.google.guava</groupId>
- <artifactId>guava</artifactId>
- </dependency>
-
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-test-junit6</artifactId>
- <scope>test</scope>
- </dependency>
- </dependencies>
-</project>
diff --git
a/components/camel-guava-eventbus/src/generated/java/org/apache/camel/component/guava/eventbus/GuavaEventBusComponentConfigurer.java
b/components/camel-guava-eventbus/src/generated/java/org/apache/camel/component/guava/eventbus/GuavaEventBusComponentConfigurer.java
deleted file mode 100644
index 156b283856b3..000000000000
---
a/components/camel-guava-eventbus/src/generated/java/org/apache/camel/component/guava/eventbus/GuavaEventBusComponentConfigurer.java
+++ /dev/null
@@ -1,84 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.guava.eventbus;
-
-import javax.annotation.processing.Generated;
-import java.util.Map;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.spi.ExtendedPropertyConfigurerGetter;
-import org.apache.camel.spi.PropertyConfigurerGetter;
-import org.apache.camel.spi.ConfigurerStrategy;
-import org.apache.camel.spi.GeneratedPropertyConfigurer;
-import org.apache.camel.util.CaseInsensitiveMap;
-import org.apache.camel.support.component.PropertyConfigurerSupport;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointSchemaGeneratorMojo")
-@SuppressWarnings("unchecked")
-public class GuavaEventBusComponentConfigurer extends
PropertyConfigurerSupport implements GeneratedPropertyConfigurer,
PropertyConfigurerGetter {
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String
name, Object value, boolean ignoreCase) {
- GuavaEventBusComponent target = (GuavaEventBusComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "autowiredenabled":
- case "autowiredEnabled":
target.setAutowiredEnabled(property(camelContext, boolean.class, value));
return true;
- case "bridgeerrorhandler":
- case "bridgeErrorHandler":
target.setBridgeErrorHandler(property(camelContext, boolean.class, value));
return true;
- case "eventbus":
- case "eventBus": target.setEventBus(property(camelContext,
com.google.common.eventbus.EventBus.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer":
target.setLazyStartProducer(property(camelContext, boolean.class, value));
return true;
- case "listenerinterface":
- case "listenerInterface":
target.setListenerInterface(property(camelContext, java.lang.Class.class,
value)); return true;
- default: return false;
- }
- }
-
- @Override
- public Class<?> getOptionType(String name, boolean ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "autowiredenabled":
- case "autowiredEnabled": return boolean.class;
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": return boolean.class;
- case "eventbus":
- case "eventBus": return com.google.common.eventbus.EventBus.class;
- case "lazystartproducer":
- case "lazyStartProducer": return boolean.class;
- case "listenerinterface":
- case "listenerInterface": return java.lang.Class.class;
- default: return null;
- }
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- GuavaEventBusComponent target = (GuavaEventBusComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "autowiredenabled":
- case "autowiredEnabled": return target.isAutowiredEnabled();
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": return target.isBridgeErrorHandler();
- case "eventbus":
- case "eventBus": return target.getEventBus();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- case "listenerinterface":
- case "listenerInterface": return target.getListenerInterface();
- default: return null;
- }
- }
-
- @Override
- public Object getCollectionValueType(Object target, String name, boolean
ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "listenerinterface":
- case "listenerInterface": return java.lang.Object.class;
- default: return null;
- }
- }
-}
-
diff --git
a/components/camel-guava-eventbus/src/generated/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpointConfigurer.java
b/components/camel-guava-eventbus/src/generated/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpointConfigurer.java
deleted file mode 100644
index 5a1ec05c9d57..000000000000
---
a/components/camel-guava-eventbus/src/generated/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpointConfigurer.java
+++ /dev/null
@@ -1,92 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.guava.eventbus;
-
-import javax.annotation.processing.Generated;
-import java.util.Map;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.spi.ExtendedPropertyConfigurerGetter;
-import org.apache.camel.spi.PropertyConfigurerGetter;
-import org.apache.camel.spi.ConfigurerStrategy;
-import org.apache.camel.spi.GeneratedPropertyConfigurer;
-import org.apache.camel.util.CaseInsensitiveMap;
-import org.apache.camel.support.component.PropertyConfigurerSupport;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointSchemaGeneratorMojo")
-@SuppressWarnings("unchecked")
-public class GuavaEventBusEndpointConfigurer extends PropertyConfigurerSupport
implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String
name, Object value, boolean ignoreCase) {
- GuavaEventBusEndpoint target = (GuavaEventBusEndpoint) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "bridgeerrorhandler":
- case "bridgeErrorHandler":
target.setBridgeErrorHandler(property(camelContext, boolean.class, value));
return true;
- case "eventclass":
- case "eventClass": target.setEventClass(property(camelContext,
java.lang.Class.class, value)); return true;
- case "exceptionhandler":
- case "exceptionHandler":
target.setExceptionHandler(property(camelContext,
org.apache.camel.spi.ExceptionHandler.class, value)); return true;
- case "exchangepattern":
- case "exchangePattern":
target.setExchangePattern(property(camelContext,
org.apache.camel.ExchangePattern.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer":
target.setLazyStartProducer(property(camelContext, boolean.class, value));
return true;
- case "listenerinterface":
- case "listenerInterface":
target.setListenerInterface(property(camelContext, java.lang.Class.class,
value)); return true;
- default: return false;
- }
- }
-
- @Override
- public Class<?> getOptionType(String name, boolean ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": return boolean.class;
- case "eventclass":
- case "eventClass": return java.lang.Class.class;
- case "exceptionhandler":
- case "exceptionHandler": return
org.apache.camel.spi.ExceptionHandler.class;
- case "exchangepattern":
- case "exchangePattern": return org.apache.camel.ExchangePattern.class;
- case "lazystartproducer":
- case "lazyStartProducer": return boolean.class;
- case "listenerinterface":
- case "listenerInterface": return java.lang.Class.class;
- default: return null;
- }
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- GuavaEventBusEndpoint target = (GuavaEventBusEndpoint) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": return target.isBridgeErrorHandler();
- case "eventclass":
- case "eventClass": return target.getEventClass();
- case "exceptionhandler":
- case "exceptionHandler": return target.getExceptionHandler();
- case "exchangepattern":
- case "exchangePattern": return target.getExchangePattern();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- case "listenerinterface":
- case "listenerInterface": return target.getListenerInterface();
- default: return null;
- }
- }
-
- @Override
- public Object getCollectionValueType(Object target, String name, boolean
ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "eventclass":
- case "eventClass": return java.lang.Object.class;
- case "listenerinterface":
- case "listenerInterface": return java.lang.Object.class;
- default: return null;
- }
- }
-}
-
diff --git
a/components/camel-guava-eventbus/src/generated/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpointUriFactory.java
b/components/camel-guava-eventbus/src/generated/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpointUriFactory.java
deleted file mode 100644
index 56889bb5b022..000000000000
---
a/components/camel-guava-eventbus/src/generated/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpointUriFactory.java
+++ /dev/null
@@ -1,76 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.guava.eventbus;
-
-import javax.annotation.processing.Generated;
-import java.net.URISyntaxException;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Map;
-import java.util.Set;
-
-import org.apache.camel.spi.EndpointUriFactory;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.GenerateEndpointUriFactoryMojo")
-public class GuavaEventBusEndpointUriFactory extends
org.apache.camel.support.component.EndpointUriFactorySupport implements
EndpointUriFactory {
-
- private static final String BASE = ":eventBusRef";
-
- private static final Set<String> PROPERTY_NAMES;
- private static final Set<String> SECRET_PROPERTY_NAMES;
- private static final Map<String, String> MULTI_VALUE_PREFIXES;
- static {
- Set<String> props = new HashSet<>(7);
- props.add("bridgeErrorHandler");
- props.add("eventBusRef");
- props.add("eventClass");
- props.add("exceptionHandler");
- props.add("exchangePattern");
- props.add("lazyStartProducer");
- props.add("listenerInterface");
- PROPERTY_NAMES = Collections.unmodifiableSet(props);
- SECRET_PROPERTY_NAMES = Collections.emptySet();
- MULTI_VALUE_PREFIXES = Collections.emptyMap();
- }
-
- @Override
- public boolean isEnabled(String scheme) {
- return "guava-eventbus".equals(scheme);
- }
-
- @Override
- public String buildUri(String scheme, Map<String, Object> properties,
boolean encode) throws URISyntaxException {
- String syntax = scheme + BASE;
- String uri = syntax;
-
- Map<String, Object> copy = new HashMap<>(properties);
-
- uri = buildPathParameter(syntax, uri, "eventBusRef", null, false,
copy);
- uri = buildQueryParameters(uri, copy, encode);
- return uri;
- }
-
- @Override
- public Set<String> propertyNames() {
- return PROPERTY_NAMES;
- }
-
- @Override
- public Set<String> secretPropertyNames() {
- return SECRET_PROPERTY_NAMES;
- }
-
- @Override
- public Map<String, String> multiValuePrefixes() {
- return MULTI_VALUE_PREFIXES;
- }
-
- @Override
- public boolean isLenientProperties() {
- return false;
- }
-}
-
diff --git
a/components/camel-guava-eventbus/src/generated/resources/META-INF/org/apache/camel/component/guava/eventbus/guava-eventbus.json
b/components/camel-guava-eventbus/src/generated/resources/META-INF/org/apache/camel/component/guava/eventbus/guava-eventbus.json
deleted file mode 100644
index 96be6aa01813..000000000000
---
a/components/camel-guava-eventbus/src/generated/resources/META-INF/org/apache/camel/component/guava/eventbus/guava-eventbus.json
+++ /dev/null
@@ -1,42 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "guava-eventbus",
- "title": "Guava EventBus",
- "description": "Send and receive messages to\/from Guava EventBus.",
- "deprecated": true,
- "firstVersion": "2.10.0",
- "label": "messaging",
- "javaType":
"org.apache.camel.component.guava.eventbus.GuavaEventBusComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-guava-eventbus",
- "version": "4.21.0-SNAPSHOT",
- "scheme": "guava-eventbus",
- "extendsScheme": "",
- "syntax": "guava-eventbus:eventBusRef",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": false,
- "lenientProperties": false,
- "browsable": false,
- "remote": false
- },
- "componentProperties": {
- "eventBus": { "index": 0, "kind": "property", "displayName": "Event Bus",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "com.google.common.eventbus.EventBus", "deprecated": false,
"autowired": false, "secret": false, "description": "To use the given Guava
EventBus instance" },
- "bridgeErrorHandler": { "index": 1, "kind": "property", "displayName":
"Bridge Error Handler", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Allows for bridging the consumer to the Camel routing Error Handler, which
mean any exceptions (if possible) occurred while the Camel consumer is trying
to pickup incoming messages, or the like [...]
- "listenerInterface": { "index": 2, "kind": "property", "displayName":
"Listener Interface", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.Class<java.lang.Object>",
"deprecated": false, "autowired": false, "secret": false, "description": "The
interface with method(s) marked with the Subscribe annotation. Dynamic proxy
will be created over the interface so it could be registered as the EventBus
listener. Particularly useful when c [...]
- "lazyStartProducer": { "index": 3, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"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 [...]
- "autowiredEnabled": { "index": 4, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"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 t [...]
- },
- "properties": {
- "eventBusRef": { "index": 0, "kind": "path", "displayName": "Event Bus
Ref", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To lookup the Guava EventBus from the registry
with the given name" },
- "eventClass": { "index": 1, "kind": "parameter", "displayName": "Event
Class", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.Class<java.lang.Object>", "deprecated": false,
"autowired": false, "secret": false, "description": "If used on the consumer
side of the route, will filter events received from the EventBus to the
instances of the class and superclasses of eventClass. Null value of this
option is equal to setting it to the java.lang. [...]
- "listenerInterface": { "index": 2, "kind": "parameter", "displayName":
"Listener Interface", "group": "common", "label": "", "required": false,
"type": "string", "javaType": "java.lang.Class<java.lang.Object>",
"deprecated": false, "autowired": false, "secret": false, "description": "The
interface with method(s) marked with the Subscribe annotation. Dynamic proxy
will be created over the interface so it could be registered as the EventBus
listener. Particularly useful when creating m [...]
- "bridgeErrorHandler": { "index": 3, "kind": "parameter", "displayName":
"Bridge Error Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions (if possible) occurred
while the Camel consumer is trying to pickup incoming [...]
- "exceptionHandler": { "index": 4, "kind": "parameter", "displayName":
"Exception Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By def [...]
- "exchangePattern": { "index": 5, "kind": "parameter", "displayName":
"Exchange Pattern", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "enum", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ],
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the exchange pattern when the consumer creates an exchange." },
- "lazyStartProducer": { "index": 6, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "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 produc [...]
- }
-}
diff --git
a/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/component.properties
b/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/component.properties
deleted file mode 100644
index 459c50a27c40..000000000000
---
a/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/component.properties
+++ /dev/null
@@ -1,7 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-components=guava-eventbus
-groupId=org.apache.camel
-artifactId=camel-guava-eventbus
-version=4.21.0-SNAPSHOT
-projectName=Camel :: Guava-EventBus (deprecated)
-projectDescription=Camel Guava EventBus support
diff --git
a/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/component/guava-eventbus
b/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/component/guava-eventbus
deleted file mode 100644
index 4198077ecb62..000000000000
---
a/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/component/guava-eventbus
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.guava.eventbus.GuavaEventBusComponent
diff --git
a/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/configurer/guava-eventbus-component
b/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/configurer/guava-eventbus-component
deleted file mode 100644
index 1950be6013dc..000000000000
---
a/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/configurer/guava-eventbus-component
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.guava.eventbus.GuavaEventBusComponentConfigurer
diff --git
a/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/configurer/guava-eventbus-endpoint
b/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/configurer/guava-eventbus-endpoint
deleted file mode 100644
index b2e667d39b82..000000000000
---
a/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/configurer/guava-eventbus-endpoint
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.guava.eventbus.GuavaEventBusEndpointConfigurer
diff --git
a/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/urifactory/guava-eventbus-endpoint
b/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/urifactory/guava-eventbus-endpoint
deleted file mode 100644
index 99bd78c9f6dd..000000000000
---
a/components/camel-guava-eventbus/src/generated/resources/META-INF/services/org/apache/camel/urifactory/guava-eventbus-endpoint
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.guava.eventbus.GuavaEventBusEndpointUriFactory
diff --git
a/components/camel-guava-eventbus/src/main/docs/guava-eventbus-component.adoc
b/components/camel-guava-eventbus/src/main/docs/guava-eventbus-component.adoc
deleted file mode 100644
index e50d02a8e77c..000000000000
---
a/components/camel-guava-eventbus/src/main/docs/guava-eventbus-component.adoc
+++ /dev/null
@@ -1,188 +0,0 @@
-= Guava EventBus Component (deprecated)
-:doctitle: Guava EventBus
-:shortname: guava-eventbus
-:artifactid: camel-guava-eventbus
-:description: Send and receive messages to/from Guava EventBus.
-:since: 2.10
-:supportlevel: Stable-deprecated
-:deprecated: *deprecated*
-:tabs-sync-option:
-:component-header: Both producer and consumer are supported
-//Manually maintained attributes
-:camel-spring-boot-name: guava-eventbus
-
-*Since Camel {since}*
-
-*{component-header}*
-
-[NOTE]
-====
-This component is deprecated since Camel 4.10 and will be removed in a future
release.
-====
-
-The
-https://google.github.io/guava/releases/19.0/api/docs/com/google/common/eventbus/EventBus.html[Google
-Guava EventBus] allows publish-subscribe-style communication between
-components without requiring the components to explicitly register with
-one another (and thus be aware of each other). The *guava-eventbus:*
-component provides integration bridge between Camel and
-https://google.github.io/guava/releases/19.0/api/docs/com/google/common/eventbus/EventBus.html[Google
-Guava EventBus] infrastructure. With the latter component, messages
-exchanged with the Guava `EventBus` can be transparently forwarded to
-the Camel routes. EventBus component allows also routing the body of Camel
-exchanges to the Guava `EventBus`.
-
-Maven users will need to add the following dependency to their `pom.xml`
-for this component:
-
-[source,xml]
-------------------------------------------------------------
-<dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-guava-eventbus</artifactId>
- <version>x.x.x</version>
- <!-- use the same version as your Camel core version -->
-</dependency>
-------------------------------------------------------------
-
-== URI format
-
---------------------------------
-guava-eventbus:busName[?options]
---------------------------------
-
-Where *busName* represents the name of the
-`com.google.common.eventbus.EventBus` instance located in the Camel
-registry.
-
-
-// component options: START
-include::partial$component-configure-options.adoc[]
-include::partial$component-endpoint-options.adoc[]
-include::partial$component-endpoint-headers.adoc[]
-// component options: END
-
-
-== Usage
-
-Using `guava-eventbus` component on the consumer side of the route will
-capture messages sent to the Guava `EventBus` and forward them to the
-Camel route. Guava EventBus consumer processes incoming messages
-http://camel.apache.org/asynchronous-routing-engine.html[asynchronously].
-
-[source,java]
--------------------------------------------------------
-SimpleRegistry registry = new SimpleRegistry();
-EventBus eventBus = new EventBus();
-registry.put("busName", eventBus);
-CamelContext camel = new DefaultCamelContext(registry);
-
-from("guava-eventbus:busName").to("seda:queue");
-
-eventBus.post("Send me to the SEDA queue.");
--------------------------------------------------------
-
-Using `guava-eventbus` component on the producer side of the route will
-forward body of the Camel exchanges to the Guava `EventBus` instance.
-
-[source,java]
-----------------------------------------------------------------------
-SimpleRegistry registry = new SimpleRegistry();
-EventBus eventBus = new EventBus();
-registry.put("busName", eventBus);
-CamelContext camel = new DefaultCamelContext(registry);
-
-from("direct:start").to("guava-eventbus:busName");
-
-ProducerTemplate producerTemplate = camel.createProducerTemplate();
-producer.sendBody("direct:start", "Send me to the Guava EventBus.");
-
-eventBus.register(new Object(){
- @Subscribe
- public void messageHander(String message) {
- System.out.println("Message received from the Camel: " + message);
- }
-});
-----------------------------------------------------------------------
-
-=== DeadEvent considerations
-
-Keep in mind that due to the limitations caused by the design of the
-Guava EventBus, you cannot specify event class to be received by the
-listener without creating class annotated with `@Subscribe` method. This
-limitation implies that endpoint with `eventClass` option specified
-actually listens to all possible events (`java.lang.Object`) and filter
-appropriate messages programmatically at runtime. The snipped below
-demonstrates an appropriate excerpt from the Camel code base.
-
-[source,java]
-----------------------------------------------------------------------------
-@Subscribe
-public void eventReceived(Object event) {
- if (eventClass == null || eventClass.isAssignableFrom(event.getClass())) {
- doEventReceived(event);
-...
-----------------------------------------------------------------------------
-
-This drawback of this approach is that `EventBus` instance used by Camel
-will never generate `com.google.common.eventbus.DeadEvent`
-notifications. If you want Camel to listen only to the precisely
-specified event (and therefore enable `DeadEvent` support), use
-`listenerInterface` endpoint option. Camel will create a dynamic proxy
-over the interface you specify with the latter option and listen only to
-messages specified by the interface handler methods. The example of the
-listener interface with single method handling only `SpecificEvent`
-instances is demonstrated below.
-
-[source,java]
-------------------------------------------
-package com.example;
-
-public interface CustomListener {
-
- @Subscribe
- void eventReceived(SpecificEvent event);
-
-}
-------------------------------------------
-
-The listener presented above could be used in the endpoint definition as
-follows.
-
-[source,java]
----------------------------------------------------------------------------------------------
-from("guava-eventbus:busName?listenerInterface=com.example.CustomListener").to("seda:queue");
----------------------------------------------------------------------------------------------
-
-=== Consuming multiple types of events
-
-To define multiple types of events to be consumed by Guava
-EventBus consumer use `listenerInterface` endpoint option, as listener
-interface could provide multiple methods marked with the `@Subscribe`
-annotation.
-
-[source,java]
-------------------------------------------------
-package com.example;
-
-public interface MultipleEventsListener {
-
- @Subscribe
- void someEventReceived(SomeEvent event);
-
- @Subscribe
- void anotherEventReceived(AnotherEvent event);
-
-}
-------------------------------------------------
-
-The listener presented above could be used in the endpoint definition as
-follows.
-
-[source,java]
------------------------------------------------------------------------------------------------------
-from("guava-eventbus:busName?listenerInterface=com.example.MultipleEventsListener").to("seda:queue");
------------------------------------------------------------------------------------------------------
-
-
-include::spring-boot:partial$starter.adoc[]
diff --git
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/CamelEventHandler.java
b/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/CamelEventHandler.java
deleted file mode 100644
index 9b53f57f684c..000000000000
---
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/CamelEventHandler.java
+++ /dev/null
@@ -1,71 +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.component.guava.eventbus;
-
-import org.apache.camel.AsyncCallback;
-import org.apache.camel.AsyncProcessor;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.support.AsyncProcessorConverterHelper;
-import org.apache.camel.util.ObjectHelper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/*
- * Handler responsible for receiving events from the Guava event bus and
sending them to the Camel infrastructure.
- */
-public class CamelEventHandler {
-
- protected final Logger log =
LoggerFactory.getLogger(CamelEventHandler.class);
- protected final GuavaEventBusConsumer consumer;
- protected final GuavaEventBusEndpoint endpoint;
- protected final AsyncProcessor processor;
-
- public CamelEventHandler(GuavaEventBusConsumer consumer,
GuavaEventBusEndpoint endpoint, Processor processor) {
- ObjectHelper.notNull(endpoint, "eventBusEndpoint");
- ObjectHelper.notNull(processor, "processor");
-
- this.consumer = consumer;
- this.endpoint = endpoint;
- this.processor = AsyncProcessorConverterHelper.convert(processor);
- }
-
- /**
- * Callback executed to propagate event from Guava listener to Camel route.
- *
- * @param event the event received by Guava EventBus.
- */
- public void doEventReceived(Object event) {
- log.trace("Received event: {}", event);
- final Exchange exchange = createExchange(event);
- log.debug("Processing event: {}", event);
- // use async processor to support async routing engine
- processor.process(exchange, new AsyncCallback() {
- @Override
- public void done(boolean doneSync) {
- // noop
- }
- });
- }
-
- public Exchange createExchange(Object event) {
- Exchange exchange = consumer.createExchange(true);
- exchange.getIn().setBody(event);
- return exchange;
- }
-
-}
diff --git
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/FilteringCamelEventHandler.java
b/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/FilteringCamelEventHandler.java
deleted file mode 100644
index fe2723772cd0..000000000000
---
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/FilteringCamelEventHandler.java
+++ /dev/null
@@ -1,53 +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.component.guava.eventbus;
-
-import com.google.common.eventbus.Subscribe;
-import org.apache.camel.Processor;
-
-/**
- * Subtype of CamelEventHandler with public method marked with Guava
@Subscribe annotation. Supports filtering the
- * messages by event type on the Camel level.
- */
-public class FilteringCamelEventHandler extends CamelEventHandler {
-
- private final Class<?> eventClass;
-
- public FilteringCamelEventHandler(GuavaEventBusConsumer consumer,
GuavaEventBusEndpoint endpoint, Processor processor,
- Class<?> eventClass) {
- super(consumer, endpoint, processor);
- this.eventClass = eventClass;
- }
-
- /**
- * Guava callback executed when an event was received.
- *
- * @param event the event
- */
- @Subscribe
- public void eventReceived(Object event) {
- if (eventClass == null ||
eventClass.isAssignableFrom(event.getClass())) {
- doEventReceived(event);
- } else {
- if (log.isDebugEnabled()) {
- log.debug("Cannot process event: {} as its class type: {} is
not assignable with: {}",
- event, event.getClass().getName(),
eventClass.getName());
- }
- }
- }
-
-}
diff --git
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusComponent.java
b/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusComponent.java
deleted file mode 100644
index f4c3671881b1..000000000000
---
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusComponent.java
+++ /dev/null
@@ -1,70 +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.component.guava.eventbus;
-
-import java.util.Map;
-
-import com.google.common.eventbus.EventBus;
-import org.apache.camel.Endpoint;
-import org.apache.camel.spi.Metadata;
-import org.apache.camel.spi.annotations.Component;
-import org.apache.camel.support.DefaultComponent;
-
-@Component("guava-eventbus")
-public class GuavaEventBusComponent extends DefaultComponent {
-
- @Metadata
- private EventBus eventBus;
- @Metadata(label = "consumer")
- private Class<?> listenerInterface;
-
- public GuavaEventBusComponent() {
- }
-
- @Override
- protected Endpoint createEndpoint(String uri, String remaining,
Map<String, Object> parameters) throws Exception {
- GuavaEventBusEndpoint answer = new GuavaEventBusEndpoint(uri, this,
eventBus, listenerInterface);
- answer.setEventBusRef(remaining);
- setProperties(answer, parameters);
- return answer;
- }
-
- public EventBus getEventBus() {
- return eventBus;
- }
-
- /**
- * To use the given Guava EventBus instance
- */
- public void setEventBus(EventBus eventBus) {
- this.eventBus = eventBus;
- }
-
- public Class<?> getListenerInterface() {
- return listenerInterface;
- }
-
- /**
- * The interface with method(s) marked with the @Subscribe annotation.
Dynamic proxy will be created over the
- * interface so it could be registered as the EventBus listener.
Particularly useful when creating multi-event
- * listeners and for handling DeadEvent properly. This option cannot be
used together with eventClass option.
- */
- public void setListenerInterface(Class<?> listenerInterface) {
- this.listenerInterface = listenerInterface;
- }
-
-}
diff --git
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumer.java
b/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumer.java
deleted file mode 100644
index bdf95009f908..000000000000
---
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumer.java
+++ /dev/null
@@ -1,100 +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.component.guava.eventbus;
-
-import java.lang.reflect.InvocationHandler;
-import java.lang.reflect.Method;
-import java.lang.reflect.Proxy;
-
-import com.google.common.eventbus.EventBus;
-import com.google.common.eventbus.Subscribe;
-import org.apache.camel.Processor;
-import org.apache.camel.support.DefaultConsumer;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * Guava EventBus
(http://docs.guava-libraries.googlecode.com/git/javadoc/com/google/common/eventbus/EventBus.html)
- * consumer reading messages from the bus and forwarding them to the Camel
routes.
- */
-public class GuavaEventBusConsumer extends DefaultConsumer {
-
- private static final Logger LOG =
LoggerFactory.getLogger(GuavaEventBusConsumer.class);
-
- private final EventBus eventBus;
- private final Object eventHandler;
-
- public GuavaEventBusConsumer(GuavaEventBusEndpoint endpoint, Processor
processor, EventBus eventBus, Class<?> eventClass,
- Class<?> listenerInterface) {
- super(endpoint, processor);
-
- if (eventClass != null && listenerInterface != null) {
- throw new IllegalStateException("You cannot set both 'eventClass'
and 'listenerInterface' parameters.");
- }
-
- this.eventBus = eventBus;
- if (listenerInterface != null) {
- this.eventHandler = createListenerInterfaceProxy(endpoint,
processor, listenerInterface);
- } else {
- this.eventHandler = new FilteringCamelEventHandler(this, endpoint,
processor, eventClass);
- }
- }
-
- @Override
- protected void doStart() throws Exception {
- super.doStart();
- LOG.debug("Registering event handler: {} to EventBus: {}",
eventHandler, eventBus);
- eventBus.register(eventHandler);
- }
-
- @Override
- protected void doStop() throws Exception {
- LOG.debug("Unregistering event handler: {} from EventBus: {}",
eventHandler, eventBus);
- eventBus.unregister(eventHandler);
- super.doStop();
- }
-
- private Object createListenerInterfaceProxy(
- GuavaEventBusEndpoint endpoint, Processor processor, Class<?>
listenerInterface) {
- ClassLoader classLoader =
Thread.currentThread().getContextClassLoader();
- return Proxy.newProxyInstance(classLoader, new Class[] {
listenerInterface },
- new ListenerInterfaceHandler(this, endpoint, processor));
- }
-
- private static final class ListenerInterfaceHandler implements
InvocationHandler {
-
- private static final Logger LOG =
LoggerFactory.getLogger(ListenerInterfaceHandler.class);
-
- private final CamelEventHandler delegateHandler;
-
- private ListenerInterfaceHandler(GuavaEventBusConsumer consumer,
GuavaEventBusEndpoint endpoint, Processor processor) {
- this.delegateHandler = new CamelEventHandler(consumer, endpoint,
processor);
- }
-
- @Override
- public Object invoke(Object proxy, Method method, Object[] args)
throws Throwable {
- if (method.getAnnotation(Subscribe.class) != null) {
- delegateHandler.doEventReceived(args[0]);
- } else {
- LOG.warn("Non @Subscribe method {} called on ListenerInterface
proxy.", method);
- }
- return null;
- }
-
- }
-
-}
diff --git
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java
b/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java
deleted file mode 100644
index 3ea56e271088..000000000000
---
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusEndpoint.java
+++ /dev/null
@@ -1,133 +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.component.guava.eventbus;
-
-import com.google.common.eventbus.EventBus;
-import org.apache.camel.Category;
-import org.apache.camel.Component;
-import org.apache.camel.Consumer;
-import org.apache.camel.MultipleConsumersSupport;
-import org.apache.camel.Processor;
-import org.apache.camel.Producer;
-import org.apache.camel.spi.UriEndpoint;
-import org.apache.camel.spi.UriParam;
-import org.apache.camel.spi.UriPath;
-import org.apache.camel.support.CamelContextHelper;
-import org.apache.camel.support.DefaultEndpoint;
-
-/**
- * Send and receive messages to/from Guava EventBus.
- */
-@UriEndpoint(firstVersion = "2.10.0", scheme = "guava-eventbus", title =
"Guava EventBus",
- remote = false, syntax = "guava-eventbus:eventBusRef", category =
{ Category.MESSAGING })
-public class GuavaEventBusEndpoint extends DefaultEndpoint implements
MultipleConsumersSupport {
-
- private EventBus eventBus;
-
- @UriPath
- private String eventBusRef;
- @UriParam
- private Class<?> eventClass;
- @UriParam
- private Class<?> listenerInterface;
-
- public GuavaEventBusEndpoint(String endpointUri, Component component,
EventBus eventBus, Class<?> listenerInterface) {
- super(endpointUri, component);
- this.eventBus = eventBus;
- this.listenerInterface = listenerInterface;
- }
-
- @Override
- public boolean isRemote() {
- return false;
- }
-
- @Override
- public Producer createProducer() throws Exception {
- return new GuavaEventBusProducer(this, eventBus);
- }
-
- @Override
- public Consumer createConsumer(Processor processor) throws Exception {
- GuavaEventBusConsumer answer = new GuavaEventBusConsumer(this,
processor, eventBus, eventClass, listenerInterface);
- configureConsumer(answer);
- return answer;
- }
-
- @Override
- public boolean isMultipleConsumersSupported() {
- return true;
- }
-
- public String getEventBusRef() {
- return eventBusRef;
- }
-
- /**
- * To lookup the Guava EventBus from the registry with the given name
- */
- public void setEventBusRef(String eventBusRef) {
- this.eventBusRef = eventBusRef;
- }
-
- public EventBus getEventBus() {
- return eventBus;
- }
-
- /**
- * To use the given Guava EventBus instance
- */
- public void setEventBus(EventBus eventBus) {
- this.eventBus = eventBus;
- }
-
- public Class<?> getEventClass() {
- return eventClass;
- }
-
- /**
- * If used on the consumer side of the route, will filter events received
from the EventBus to the instances of the
- * class and superclasses of eventClass. Null value of this option is
equal to setting it to the java.lang.Object
- * i.e. the consumer will capture all messages incoming to the event bus.
This option cannot be used together with
- * listenerInterface option.
- */
- public void setEventClass(Class<?> eventClass) {
- this.eventClass = eventClass;
- }
-
- public Class<?> getListenerInterface() {
- return listenerInterface;
- }
-
- /**
- * The interface with method(s) marked with the @Subscribe annotation.
Dynamic proxy will be created over the
- * interface so it could be registered as the EventBus listener.
Particularly useful when creating multi-event
- * listeners and for handling DeadEvent properly. This option cannot be
used together with eventClass option.
- */
- public void setListenerInterface(Class<?> listenerInterface) {
- this.listenerInterface = listenerInterface;
- }
-
- @Override
- protected void doInit() throws Exception {
- super.doInit();
-
- if (eventBusRef != null && eventBus == null) {
- eventBus = CamelContextHelper.mandatoryLookup(getCamelContext(),
eventBusRef, EventBus.class);
- }
- }
-}
diff --git
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusProducer.java
b/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusProducer.java
deleted file mode 100644
index 1c4f08393cd5..000000000000
---
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/GuavaEventBusProducer.java
+++ /dev/null
@@ -1,52 +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.component.guava.eventbus;
-
-import com.google.common.eventbus.EventBus;
-import org.apache.camel.Endpoint;
-import org.apache.camel.Exchange;
-import org.apache.camel.support.DefaultProducer;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * Guava EventBus
(http://docs.guava-libraries.googlecode.com/git/javadoc/com/google/common/eventbus/EventBus.html)
- * producer forwarding messages from Camel routes to the bus.
- */
-public class GuavaEventBusProducer extends DefaultProducer {
-
- private static final Logger LOG =
LoggerFactory.getLogger(GuavaEventBusProducer.class);
-
- private final EventBus eventBus;
-
- public GuavaEventBusProducer(Endpoint endpoint, EventBus eventBus) {
- super(endpoint);
- this.eventBus = eventBus;
- }
-
- @Override
- public void process(Exchange exchange) throws Exception {
- Object body = exchange.getIn().getBody();
- if (body != null) {
- LOG.debug("Posting: {} to EventBus: {}", body, eventBus);
- eventBus.post(body);
- } else {
- LOG.debug("Body is null, cannot post to EventBus");
- }
- }
-
-}
diff --git
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomListener.java
b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomListener.java
deleted file mode 100644
index c26b7cabe87a..000000000000
---
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomListener.java
+++ /dev/null
@@ -1,26 +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.component.guava.eventbus;
-
-import com.google.common.eventbus.Subscribe;
-
-public interface CustomListener {
-
- @Subscribe
- void eventReceived(MessageWrapper messageWrapper);
-
-}
diff --git
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomMultiEventListener.java
b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomMultiEventListener.java
deleted file mode 100644
index a53e30910863..000000000000
---
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomMultiEventListener.java
+++ /dev/null
@@ -1,31 +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.component.guava.eventbus;
-
-import java.util.Date;
-
-import com.google.common.eventbus.Subscribe;
-
-public interface CustomMultiEventListener {
-
- @Subscribe
- void stringReceived(String stringEvent);
-
- @Subscribe
- void dateReceived(Date dateEvent);
-
-}
diff --git
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/DeadEventListener.java
b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/DeadEventListener.java
deleted file mode 100644
index 07ffad2637c9..000000000000
---
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/DeadEventListener.java
+++ /dev/null
@@ -1,27 +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.component.guava.eventbus;
-
-import com.google.common.eventbus.DeadEvent;
-import com.google.common.eventbus.Subscribe;
-
-public interface DeadEventListener {
-
- @Subscribe
- void deadEventReceived(DeadEvent deadEvent);
-
-}
diff --git
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusComponentTest.java
b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusComponentTest.java
deleted file mode 100644
index e8b5dd88938b..000000000000
---
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusComponentTest.java
+++ /dev/null
@@ -1,67 +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.component.guava.eventbus;
-
-import com.google.common.eventbus.EventBus;
-import org.apache.camel.BindToRegistry;
-import org.apache.camel.CamelContext;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.junit6.CamelTestSupport;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class GuavaEventBusComponentTest extends CamelTestSupport {
-
- @BindToRegistry("eventBus")
- EventBus eventBus = new EventBus();
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- @Override
- public void configure() {
- from("myGuavaEventBus:eventBus").to("mock:test");
- }
- };
- }
-
- @Override
- protected CamelContext createCamelContext() throws Exception {
- CamelContext camelContext = super.createCamelContext();
- GuavaEventBusComponent busComponent = new GuavaEventBusComponent();
- busComponent.setEventBus(eventBus);
- camelContext.addComponent("myGuavaEventBus", busComponent);
- return camelContext;
- }
-
- @Test
- public void shouldForwardMessageToCustomComponent() throws
InterruptedException {
- // Given
- String message = "message";
-
- // When
- eventBus.post(message);
-
- // Then
- getMockEndpoint("mock:test").setExpectedMessageCount(1);
- MockEndpoint.assertIsSatisfied(context);
- assertEquals(message,
getMockEndpoint("mock:test").getExchanges().get(0).getIn().getBody());
- }
-
-}
diff --git
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerConfigurationTest.java
b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerConfigurationTest.java
deleted file mode 100644
index 7dbb5253384d..000000000000
---
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerConfigurationTest.java
+++ /dev/null
@@ -1,59 +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.component.guava.eventbus;
-
-import com.google.common.eventbus.EventBus;
-import org.apache.camel.CamelContext;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.impl.DefaultCamelContext;
-import org.apache.camel.support.SimpleRegistry;
-import org.apache.camel.test.junit6.CamelTestSupport;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.test.junit6.TestSupport.assertIsInstanceOf;
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertThrows;
-
-public class GuavaEventBusConsumerConfigurationTest extends CamelTestSupport {
-
- @Override
- public boolean isUseRouteBuilder() {
- return false;
- }
-
- @Test
- public void invalidConfiguration() throws Exception {
- // Given
- SimpleRegistry registry = new SimpleRegistry();
- registry.bind("eventBus", new EventBus());
- CamelContext context = new DefaultCamelContext(registry);
- context.addRoutes(new RouteBuilder() {
- @Override
- public void configure() {
-
from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.CustomListener&eventClass=org.apache.camel.component.guava.eventbus.MessageWrapper")
- .to("mock:customListenerEvents");
- }
- });
-
- Exception e = assertThrows(Exception.class, () -> {
- context.start();
- });
- IllegalStateException ise =
assertIsInstanceOf(IllegalStateException.class, e.getCause());
- assertEquals("You cannot set both 'eventClass' and 'listenerInterface'
parameters.", ise.getMessage());
- }
-
-}
diff --git
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerTest.java
b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerTest.java
deleted file mode 100644
index 3ceb8c86dfd9..000000000000
---
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerTest.java
+++ /dev/null
@@ -1,133 +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.component.guava.eventbus;
-
-import java.util.Date;
-
-import com.google.common.eventbus.EventBus;
-import org.apache.camel.BindToRegistry;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.junit6.CamelTestSupport;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class GuavaEventBusConsumerTest extends CamelTestSupport {
-
- @BindToRegistry("eventBus")
- EventBus eventBus = new EventBus();
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- @Override
- public void configure() {
- from("guava-eventbus:eventBus").to("mock:allEvents");
- from("guava-eventbus:eventBus").to("mock:multipliedConsumer");
-
-
from("guava-eventbus:eventBus?eventClass=org.apache.camel.component.guava.eventbus.MessageWrapper")
- .to("mock:wrapperEvents");
-
-
from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.CustomListener")
- .to("mock:customListenerEvents");
-
-
from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.CustomMultiEventListener")
- .to("mock:customMultiEventListenerEvents");
- }
- };
- }
-
- @Test
- public void shouldForwardMessageToCamel() throws InterruptedException {
- // Given
- String message = "message";
-
- // When
- eventBus.post(message);
-
- // Then
- getMockEndpoint("mock:allEvents").setExpectedMessageCount(1);
- MockEndpoint.assertIsSatisfied(context);
- assertEquals(message,
getMockEndpoint("mock:allEvents").getExchanges().get(0).getIn().getBody());
- }
-
- @Test
- public void shouldForwardMessageToMultipleConsumers() throws
InterruptedException {
- // Given
- String message = "message";
-
- // When
- eventBus.post(message);
-
- // Then
- getMockEndpoint("mock:allEvents").setExpectedMessageCount(1);
- getMockEndpoint("mock:multipliedConsumer").setExpectedMessageCount(1);
- MockEndpoint.assertIsSatisfied(context);
- assertEquals(message,
getMockEndpoint("mock:allEvents").getExchanges().get(0).getIn().getBody());
- assertEquals(message,
getMockEndpoint("mock:multipliedConsumer").getExchanges().get(0).getIn().getBody());
- }
-
- @Test
- public void shouldFilterForwardedMessages() throws InterruptedException {
- // Given
- MessageWrapper wrappedMessage = new MessageWrapper("message");
-
- // When
- eventBus.post(wrappedMessage);
- eventBus.post("String message.");
-
- // Then
- getMockEndpoint("mock:wrapperEvents").setExpectedMessageCount(1);
- MockEndpoint.assertIsSatisfied(context);
- assertEquals(wrappedMessage,
getMockEndpoint("mock:wrapperEvents").getExchanges().get(0).getIn().getBody());
- }
-
- @Test
- public void shouldUseCustomListener() throws InterruptedException {
- // Given
- MessageWrapper wrappedMessage = new MessageWrapper("message");
-
- // When
- eventBus.post(wrappedMessage);
- eventBus.post("String message.");
-
- // Then
-
getMockEndpoint("mock:customListenerEvents").setExpectedMessageCount(1);
- MockEndpoint.assertIsSatisfied(context);
- assertEquals(wrappedMessage,
getMockEndpoint("mock:customListenerEvents").getExchanges().get(0).getIn().getBody());
- }
-
- @Test
- public void shouldSupportMultiEventCustomListener() throws
InterruptedException {
- // Given
- String stringEvent = "stringEvent";
- Date dateEvent = new Date();
-
- // When
- eventBus.post(stringEvent);
- eventBus.post(dateEvent);
-
- // Then
-
getMockEndpoint("mock:customMultiEventListenerEvents").setExpectedMessageCount(2);
- MockEndpoint.assertIsSatisfied(context);
- assertEquals(stringEvent,
-
getMockEndpoint("mock:customMultiEventListenerEvents").getExchanges().get(0).getIn().getBody());
- assertEquals(dateEvent,
getMockEndpoint("mock:customMultiEventListenerEvents").getExchanges().get(1).getIn().getBody());
- }
-
-}
diff --git
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumingDeadEventsTest.java
b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumingDeadEventsTest.java
deleted file mode 100644
index f3b82fea42d9..000000000000
---
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumingDeadEventsTest.java
+++ /dev/null
@@ -1,67 +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.component.guava.eventbus;
-
-import java.util.Date;
-
-import com.google.common.eventbus.DeadEvent;
-import com.google.common.eventbus.EventBus;
-import org.apache.camel.BindToRegistry;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.junit6.CamelTestSupport;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class GuavaEventBusConsumingDeadEventsTest extends CamelTestSupport {
-
- @BindToRegistry("eventBus")
- EventBus eventBus = new EventBus();
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- @Override
- public void configure() {
-
from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.CustomListener")
- .to("mock:customListenerEvents");
-
-
from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.DeadEventListener")
- .to("mock:deadEvents");
- }
- };
- }
-
- @Test
- public void shouldForwardMessageToCamel() throws InterruptedException {
- // Given
- Date message = new Date();
-
- // When
- eventBus.post(message);
-
- // Then
-
getMockEndpoint("mock:customListenerEvents").setExpectedMessageCount(0);
- MockEndpoint.assertIsSatisfied(context);
- getMockEndpoint("mock:deadEvents").setExpectedMessageCount(1);
- MockEndpoint.assertIsSatisfied(context);
- assertEquals(message,
-
getMockEndpoint("mock:deadEvents").getExchanges().get(0).getIn().getBody(DeadEvent.class).getEvent());
- }
-
-}
diff --git
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusProducerTest.java
b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusProducerTest.java
deleted file mode 100644
index f41984270f01..000000000000
---
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusProducerTest.java
+++ /dev/null
@@ -1,63 +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.component.guava.eventbus;
-
-import com.google.common.eventbus.EventBus;
-import com.google.common.eventbus.Subscribe;
-import org.apache.camel.BindToRegistry;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.test.junit6.CamelTestSupport;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class GuavaEventBusProducerTest extends CamelTestSupport {
-
- @BindToRegistry("eventBus")
- EventBus eventBus = new EventBus();
-
- Object receivedEvent;
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- @Override
- public void configure() {
- from("direct:start").to("guava-eventbus:eventBus");
- }
- };
- }
-
- @Test
- public void shouldReceiveMessageFromCamel() {
- // Given
- String message = "message";
- eventBus.register(this);
-
- // When
- sendBody("direct:start", message);
-
- // Then
- assertEquals(message, receivedEvent);
- }
-
- @Subscribe
- public void receiveEvent(Object event) {
- this.receivedEvent = event;
- }
-
-}
diff --git
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/MessageWrapper.java
b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/MessageWrapper.java
deleted file mode 100644
index 4574db2a3a7c..000000000000
---
a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/MessageWrapper.java
+++ /dev/null
@@ -1,31 +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.component.guava.eventbus;
-
-public class MessageWrapper {
-
- private String message;
-
- public MessageWrapper(String message) {
- this.message = message;
- }
-
- public String getMessage() {
- return message;
- }
-
-}
diff --git
a/components/camel-guava-eventbus/src/test/resources/log4j2.properties
b/components/camel-guava-eventbus/src/test/resources/log4j2.properties
deleted file mode 100644
index b44bd26b29cf..000000000000
--- a/components/camel-guava-eventbus/src/test/resources/log4j2.properties
+++ /dev/null
@@ -1,28 +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.
-## ---------------------------------------------------------------------------
-
-appender.file.type = File
-appender.file.name = file
-appender.file.fileName = target/camel-guava-eventbus-test.log
-appender.file.layout.type = PatternLayout
-appender.file.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-appender.out.type = Console
-appender.out.name = out
-appender.out.layout.type = PatternLayout
-appender.out.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-rootLogger.level = INFO
-rootLogger.appenderRef.file.ref = file
diff --git a/components/pom.xml b/components/pom.xml
index 8581076f7ae3..05dbbbddca24 100644
--- a/components/pom.xml
+++ b/components/pom.xml
@@ -156,7 +156,6 @@
<module>camel-grok</module>
<module>camel-grpc</module>
<module>camel-gson</module>
- <module>camel-guava-eventbus</module>
<module>camel-hashicorp-vault</module>
<module>camel-hazelcast</module>
<module>camel-headersmap</module>
diff --git
a/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
b/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
index 75a89701c5e4..593e5fe612b4 100644
---
a/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
+++
b/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
@@ -147,7 +147,6 @@ google-vision
grape
graphql
grpc
-guava-eventbus
hashicorp-vault
hazelcast-atomicvalue
hazelcast-instance
diff --git a/coverage/pom.xml b/coverage/pom.xml
index 6c43086ce3f8..47e669441e6f 100644
--- a/coverage/pom.xml
+++ b/coverage/pom.xml
@@ -1027,11 +1027,6 @@
<artifactId>camel-gson</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-guava-eventbus</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-hashicorp-vault</artifactId>
diff --git a/docs/components/modules/ROOT/examples/json/guava-eventbus.json
b/docs/components/modules/ROOT/examples/json/guava-eventbus.json
deleted file mode 120000
index 51907b9fac4c..000000000000
--- a/docs/components/modules/ROOT/examples/json/guava-eventbus.json
+++ /dev/null
@@ -1 +0,0 @@
-../../../../../../components/camel-guava-eventbus/src/generated/resources/META-INF/org/apache/camel/component/guava/eventbus/guava-eventbus.json
\ No newline at end of file
diff --git a/docs/components/modules/ROOT/nav.adoc
b/docs/components/modules/ROOT/nav.adoc
index d2c3d85f2f1f..5718f9e41e46 100644
--- a/docs/components/modules/ROOT/nav.adoc
+++ b/docs/components/modules/ROOT/nav.adoc
@@ -174,7 +174,6 @@
** xref:grape-component.adoc[Grape]
** xref:graphql-component.adoc[GraphQL]
** xref:grpc-component.adoc[gRPC]
-** xref:guava-eventbus-component.adoc[Guava EventBus]
** xref:hashicorp-vault-component.adoc[Hashicorp Vault]
** xref:hazelcast-summary.adoc[Hazelcast]
*** xref:hazelcast-atomicvalue-component.adoc[Hazelcast Atomic Number]
diff --git a/docs/components/modules/ROOT/pages/guava-eventbus-component.adoc
b/docs/components/modules/ROOT/pages/guava-eventbus-component.adoc
deleted file mode 120000
index df71692506d7..000000000000
--- a/docs/components/modules/ROOT/pages/guava-eventbus-component.adoc
+++ /dev/null
@@ -1 +0,0 @@
-../../../../../components/camel-guava-eventbus/src/main/docs/guava-eventbus-component.adoc
\ No newline at end of file
diff --git
a/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_21.adoc
b/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_21.adoc
index cd2f3d93b959..4d54e758f558 100644
--- a/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_21.adoc
+++ b/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_21.adoc
@@ -128,6 +128,10 @@ Camel stomp was deprecated with Camel 4.17. The stomp
library didn't have any ac
Camel AWS X-Ray was deprecated with Camel 4.17. Amazon Web Services X-Ray
service is in maintenance mode since February 2026. The component is now
removed.
+=== camel-guava-eventbus removal
+
+Camel Guava EventBus was deprecated with Camel 4.6. The component is now
removed.
+
=== camel-telemetry
If you have custom telemetry implementations, the following interfaces have
changed:
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 244293d099f0..8264070da060 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
@@ -2026,19 +2026,6 @@ public interface ComponentsBuilderFactory {
static GrpcComponentBuilderFactory.GrpcComponentBuilder grpc() {
return GrpcComponentBuilderFactory.grpc();
}
- /**
- * Guava EventBus (camel-guava-eventbus)
- * Send and receive messages to/from Guava EventBus.
- *
- * Category: messaging
- * Since: 2.10
- * Maven coordinates: org.apache.camel:camel-guava-eventbus
- *
- * @return the dsl builder
- */
- static GuavaEventbusComponentBuilderFactory.GuavaEventbusComponentBuilder
guavaEventbus() {
- return GuavaEventbusComponentBuilderFactory.guavaEventbus();
- }
/**
* Hashicorp Vault (camel-hashicorp-vault)
* Manage secrets in Hashicorp Vault Service
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/GuavaEventbusComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/GuavaEventbusComponentBuilderFactory.java
deleted file mode 100644
index 44ad38988186..000000000000
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/GuavaEventbusComponentBuilderFactory.java
+++ /dev/null
@@ -1,187 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-/*
- * 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.processing.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.guava.eventbus.GuavaEventBusComponent;
-
-/**
- * Send and receive messages to/from Guava EventBus.
- *
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
-public interface GuavaEventbusComponentBuilderFactory {
-
- /**
- * Guava EventBus (camel-guava-eventbus)
- * Send and receive messages to/from Guava EventBus.
- *
- * Category: messaging
- * Since: 2.10
- * Maven coordinates: org.apache.camel:camel-guava-eventbus
- *
- * @return the dsl builder
- */
- static GuavaEventbusComponentBuilder guavaEventbus() {
- return new GuavaEventbusComponentBuilderImpl();
- }
-
- /**
- * Builder for the Guava EventBus component.
- */
- interface GuavaEventbusComponentBuilder extends
ComponentBuilder<GuavaEventBusComponent> {
-
- /**
- * To use the given Guava EventBus instance.
- *
- * The option is a:
- * <code>com.google.common.eventbus.EventBus</code> type.
- *
- * Group: common
- *
- * @param eventBus the value to set
- * @return the dsl builder
- */
- default GuavaEventbusComponentBuilder
eventBus(com.google.common.eventbus.EventBus eventBus) {
- doSetProperty("eventBus", eventBus);
- return this;
- }
-
-
- /**
- * Allows for bridging the consumer to the Camel routing Error Handler,
- * which mean any exceptions (if possible) occurred while the Camel
- * consumer is trying to pickup incoming messages, or the likes, will
- * now be processed as a message and handled by the routing Error
- * Handler. Important: This is only possible if the 3rd party component
- * allows Camel to be alerted if an exception was thrown. Some
- * components handle this internally only, and therefore
- * bridgeErrorHandler is not possible. In other situations we may
- * improve the Camel component to hook into the 3rd party component and
- * make this possible for future releases. 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 GuavaEventbusComponentBuilder bridgeErrorHandler(boolean
bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
-
- /**
- * The interface with method(s) marked with the Subscribe annotation.
- * Dynamic proxy will be created over the interface so it could be
- * registered as the EventBus listener. Particularly useful when
- * creating multi-event listeners and for handling DeadEvent properly.
- * This option cannot be used together with eventClass option.
- *
- * The option is a:
- *
<code>java.lang.Class&lt;java.lang.Object&gt;</code> type.
- *
- * Group: consumer
- *
- * @param listenerInterface the value to set
- * @return the dsl builder
- */
- default GuavaEventbusComponentBuilder
listenerInterface(java.lang.Class<java.lang.Object> listenerInterface) {
- doSetProperty("listenerInterface", listenerInterface);
- 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 GuavaEventbusComponentBuilder 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 GuavaEventbusComponentBuilder autowiredEnabled(boolean
autowiredEnabled) {
- doSetProperty("autowiredEnabled", autowiredEnabled);
- return this;
- }
- }
-
- class GuavaEventbusComponentBuilderImpl
- extends AbstractComponentBuilder<GuavaEventBusComponent>
- implements GuavaEventbusComponentBuilder {
- @Override
- protected GuavaEventBusComponent buildConcreteComponent() {
- return new GuavaEventBusComponent();
- }
- @Override
- protected boolean setPropertyOnComponent(
- Component component,
- String name,
- Object value) {
- switch (name) {
- case "eventBus": ((GuavaEventBusComponent)
component).setEventBus((com.google.common.eventbus.EventBus) value); return
true;
- case "bridgeErrorHandler": ((GuavaEventBusComponent)
component).setBridgeErrorHandler((boolean) value); return true;
- case "listenerInterface": ((GuavaEventBusComponent)
component).setListenerInterface((java.lang.Class) value); return true;
- case "lazyStartProducer": ((GuavaEventBusComponent)
component).setLazyStartProducer((boolean) value); return true;
- case "autowiredEnabled": ((GuavaEventBusComponent)
component).setAutowiredEnabled((boolean) value); return true;
- default: return false;
- }
- }
- }
-}
\ No newline at end of file
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 d7301eba3df0..fcf54346bdfe 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
@@ -157,7 +157,6 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.GraphqlEndpointBuilderFactory.GraphqlBuilders,
org.apache.camel.builder.endpoint.dsl.GridFsEndpointBuilderFactory.GridFsBuilders,
org.apache.camel.builder.endpoint.dsl.GrpcEndpointBuilderFactory.GrpcBuilders,
-
org.apache.camel.builder.endpoint.dsl.GuavaEventBusEndpointBuilderFactory.GuavaEventBusBuilders,
org.apache.camel.builder.endpoint.dsl.HashicorpVaultEndpointBuilderFactory.HashicorpVaultBuilders,
org.apache.camel.builder.endpoint.dsl.HazelcastAtomicnumberEndpointBuilderFactory.HazelcastAtomicnumberBuilders,
org.apache.camel.builder.endpoint.dsl.HazelcastInstanceEndpointBuilderFactory.HazelcastInstanceBuilders,
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 3b4215b50270..778db88049c7 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
@@ -154,7 +154,6 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.GraphqlEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.GridFsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.GrpcEndpointBuilderFactory,
-
org.apache.camel.builder.endpoint.dsl.GuavaEventBusEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HashicorpVaultEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HazelcastAtomicnumberEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HazelcastInstanceEndpointBuilderFactory,
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 3a5a55431e67..1f66c84301fd 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
@@ -6649,48 +6649,6 @@ public class StaticEndpointBuilders {
public static GrpcEndpointBuilderFactory.GrpcEndpointBuilder grpc(String
componentName, String path) {
return GrpcEndpointBuilderFactory.endpointBuilder(componentName, path);
}
- /**
- * Guava EventBus (camel-guava-eventbus)
- * Send and receive messages to/from Guava EventBus.
- *
- * Category: messaging
- * Since: 2.10
- * Maven coordinates: org.apache.camel:camel-guava-eventbus
- *
- * Syntax: <code>guava-eventbus:eventBusRef</code>
- *
- * Path parameter: eventBusRef
- * To lookup the Guava EventBus from the registry with the given name
- *
- * @param path eventBusRef
- * @return the dsl builder
- */
- @Deprecated
- public static
GuavaEventBusEndpointBuilderFactory.GuavaEventBusEndpointBuilder
guavaEventbus(String path) {
- return guavaEventbus("guava-eventbus", path);
- }
- /**
- * Guava EventBus (camel-guava-eventbus)
- * Send and receive messages to/from Guava EventBus.
- *
- * Category: messaging
- * Since: 2.10
- * Maven coordinates: org.apache.camel:camel-guava-eventbus
- *
- * Syntax: <code>guava-eventbus:eventBusRef</code>
- *
- * Path parameter: eventBusRef
- * To lookup the Guava EventBus from the registry with the given name
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path eventBusRef
- * @return the dsl builder
- */
- @Deprecated
- public static
GuavaEventBusEndpointBuilderFactory.GuavaEventBusEndpointBuilder
guavaEventbus(String componentName, String path) {
- return
GuavaEventBusEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
/**
* Hashicorp Vault (camel-hashicorp-vault)
* Manage secrets in Hashicorp Vault Service
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GuavaEventBusEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GuavaEventBusEndpointBuilderFactory.java
deleted file mode 100644
index 1afdb54f7053..000000000000
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GuavaEventBusEndpointBuilderFactory.java
+++ /dev/null
@@ -1,557 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-/*
- * 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.concurrent.*;
-import java.util.function.*;
-import java.util.stream.*;
-import javax.annotation.processing.Generated;
-import org.apache.camel.builder.EndpointConsumerBuilder;
-import org.apache.camel.builder.EndpointProducerBuilder;
-import org.apache.camel.builder.endpoint.AbstractEndpointBuilder;
-
-/**
- * Send and receive messages to/from Guava EventBus.
- *
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
-public interface GuavaEventBusEndpointBuilderFactory {
-
- /**
- * Builder for endpoint consumers for the Guava EventBus component.
- */
- public interface GuavaEventBusEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default AdvancedGuavaEventBusEndpointConsumerBuilder advanced() {
- return (AdvancedGuavaEventBusEndpointConsumerBuilder) this;
- }
- /**
- * If used on the consumer side of the route, will filter events
- * received from the EventBus to the instances of the class and
- * superclasses of eventClass. Null value of this option is equal to
- * setting it to the java.lang.Object i.e. the consumer will capture
all
- * messages incoming to the event bus. This option cannot be used
- * together with listenerInterface option.
- *
- * The option is a:
<code>java.lang.Class<java.lang.Object></code>
- * type.
- *
- * Group: common
- *
- * @param eventClass the value to set
- * @return the dsl builder
- */
- default GuavaEventBusEndpointConsumerBuilder
eventClass(Class<java.lang.Object> eventClass) {
- doSetProperty("eventClass", eventClass);
- return this;
- }
- /**
- * If used on the consumer side of the route, will filter events
- * received from the EventBus to the instances of the class and
- * superclasses of eventClass. Null value of this option is equal to
- * setting it to the java.lang.Object i.e. the consumer will capture
all
- * messages incoming to the event bus. This option cannot be used
- * together with listenerInterface option.
- *
- * The option will be converted to a
- * <code>java.lang.Class<java.lang.Object></code> type.
- *
- * Group: common
- *
- * @param eventClass the value to set
- * @return the dsl builder
- */
- default GuavaEventBusEndpointConsumerBuilder eventClass(String
eventClass) {
- doSetProperty("eventClass", eventClass);
- return this;
- }
- /**
- * The interface with method(s) marked with the Subscribe annotation.
- * Dynamic proxy will be created over the interface so it could be
- * registered as the EventBus listener. Particularly useful when
- * creating multi-event listeners and for handling DeadEvent properly.
- * This option cannot be used together with eventClass option.
- *
- * The option is a:
<code>java.lang.Class<java.lang.Object></code>
- * type.
- *
- * Group: common
- *
- * @param listenerInterface the value to set
- * @return the dsl builder
- */
- default GuavaEventBusEndpointConsumerBuilder
listenerInterface(Class<java.lang.Object> listenerInterface) {
- doSetProperty("listenerInterface", listenerInterface);
- return this;
- }
- /**
- * The interface with method(s) marked with the Subscribe annotation.
- * Dynamic proxy will be created over the interface so it could be
- * registered as the EventBus listener. Particularly useful when
- * creating multi-event listeners and for handling DeadEvent properly.
- * This option cannot be used together with eventClass option.
- *
- * The option will be converted to a
- * <code>java.lang.Class<java.lang.Object></code> type.
- *
- * Group: common
- *
- * @param listenerInterface the value to set
- * @return the dsl builder
- */
- default GuavaEventBusEndpointConsumerBuilder listenerInterface(String
listenerInterface) {
- doSetProperty("listenerInterface", listenerInterface);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint consumers for the Guava EventBus
component.
- */
- public interface AdvancedGuavaEventBusEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default GuavaEventBusEndpointConsumerBuilder basic() {
- return (GuavaEventBusEndpointConsumerBuilder) this;
- }
- /**
- * Allows for bridging the consumer to the Camel routing Error Handler,
- * which mean any exceptions (if possible) occurred while the Camel
- * consumer is trying to pickup incoming messages, or the likes, will
- * now be processed as a message and handled by the routing Error
- * Handler. Important: This is only possible if the 3rd party component
- * allows Camel to be alerted if an exception was thrown. Some
- * components handle this internally only, and therefore
- * bridgeErrorHandler is not possible. In other situations we may
- * improve the Camel component to hook into the 3rd party component and
- * make this possible for future releases. 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 (advanced)
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default AdvancedGuavaEventBusEndpointConsumerBuilder
bridgeErrorHandler(boolean bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * Allows for bridging the consumer to the Camel routing Error Handler,
- * which mean any exceptions (if possible) occurred while the Camel
- * consumer is trying to pickup incoming messages, or the likes, will
- * now be processed as a message and handled by the routing Error
- * Handler. Important: This is only possible if the 3rd party component
- * allows Camel to be alerted if an exception was thrown. Some
- * components handle this internally only, and therefore
- * bridgeErrorHandler is not possible. In other situations we may
- * improve the Camel component to hook into the 3rd party component and
- * make this possible for future releases. 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 (advanced)
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default AdvancedGuavaEventBusEndpointConsumerBuilder
bridgeErrorHandler(String bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- 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 is a: <code>org.apache.camel.spi.ExceptionHandler</code>
- * type.
- *
- * Group: consumer (advanced)
- *
- * @param exceptionHandler the value to set
- * @return the dsl builder
- */
- default AdvancedGuavaEventBusEndpointConsumerBuilder
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 AdvancedGuavaEventBusEndpointConsumerBuilder
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 AdvancedGuavaEventBusEndpointConsumerBuilder
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 AdvancedGuavaEventBusEndpointConsumerBuilder
exchangePattern(String exchangePattern) {
- doSetProperty("exchangePattern", exchangePattern);
- return this;
- }
- }
-
- /**
- * Builder for endpoint producers for the Guava EventBus component.
- */
- public interface GuavaEventBusEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default AdvancedGuavaEventBusEndpointProducerBuilder advanced() {
- return (AdvancedGuavaEventBusEndpointProducerBuilder) this;
- }
-
- /**
- * If used on the consumer side of the route, will filter events
- * received from the EventBus to the instances of the class and
- * superclasses of eventClass. Null value of this option is equal to
- * setting it to the java.lang.Object i.e. the consumer will capture
all
- * messages incoming to the event bus. This option cannot be used
- * together with listenerInterface option.
- *
- * The option is a:
<code>java.lang.Class<java.lang.Object></code>
- * type.
- *
- * Group: common
- *
- * @param eventClass the value to set
- * @return the dsl builder
- */
- default GuavaEventBusEndpointProducerBuilder
eventClass(Class<java.lang.Object> eventClass) {
- doSetProperty("eventClass", eventClass);
- return this;
- }
- /**
- * If used on the consumer side of the route, will filter events
- * received from the EventBus to the instances of the class and
- * superclasses of eventClass. Null value of this option is equal to
- * setting it to the java.lang.Object i.e. the consumer will capture
all
- * messages incoming to the event bus. This option cannot be used
- * together with listenerInterface option.
- *
- * The option will be converted to a
- * <code>java.lang.Class<java.lang.Object></code> type.
- *
- * Group: common
- *
- * @param eventClass the value to set
- * @return the dsl builder
- */
- default GuavaEventBusEndpointProducerBuilder eventClass(String
eventClass) {
- doSetProperty("eventClass", eventClass);
- return this;
- }
- /**
- * The interface with method(s) marked with the Subscribe annotation.
- * Dynamic proxy will be created over the interface so it could be
- * registered as the EventBus listener. Particularly useful when
- * creating multi-event listeners and for handling DeadEvent properly.
- * This option cannot be used together with eventClass option.
- *
- * The option is a:
<code>java.lang.Class<java.lang.Object></code>
- * type.
- *
- * Group: common
- *
- * @param listenerInterface the value to set
- * @return the dsl builder
- */
- default GuavaEventBusEndpointProducerBuilder
listenerInterface(Class<java.lang.Object> listenerInterface) {
- doSetProperty("listenerInterface", listenerInterface);
- return this;
- }
- /**
- * The interface with method(s) marked with the Subscribe annotation.
- * Dynamic proxy will be created over the interface so it could be
- * registered as the EventBus listener. Particularly useful when
- * creating multi-event listeners and for handling DeadEvent properly.
- * This option cannot be used together with eventClass option.
- *
- * The option will be converted to a
- * <code>java.lang.Class<java.lang.Object></code> type.
- *
- * Group: common
- *
- * @param listenerInterface the value to set
- * @return the dsl builder
- */
- default GuavaEventBusEndpointProducerBuilder listenerInterface(String
listenerInterface) {
- doSetProperty("listenerInterface", listenerInterface);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint producers for the Guava EventBus
component.
- */
- public interface AdvancedGuavaEventBusEndpointProducerBuilder extends
EndpointProducerBuilder {
- default GuavaEventBusEndpointProducerBuilder basic() {
- return (GuavaEventBusEndpointProducerBuilder) 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 (advanced)
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default AdvancedGuavaEventBusEndpointProducerBuilder
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 (advanced)
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default AdvancedGuavaEventBusEndpointProducerBuilder
lazyStartProducer(String lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- }
-
- /**
- * Builder for endpoint for the Guava EventBus component.
- */
- public interface GuavaEventBusEndpointBuilder
- extends
- GuavaEventBusEndpointConsumerBuilder,
- GuavaEventBusEndpointProducerBuilder {
- default AdvancedGuavaEventBusEndpointBuilder advanced() {
- return (AdvancedGuavaEventBusEndpointBuilder) this;
- }
-
- /**
- * If used on the consumer side of the route, will filter events
- * received from the EventBus to the instances of the class and
- * superclasses of eventClass. Null value of this option is equal to
- * setting it to the java.lang.Object i.e. the consumer will capture
all
- * messages incoming to the event bus. This option cannot be used
- * together with listenerInterface option.
- *
- * The option is a:
<code>java.lang.Class<java.lang.Object></code>
- * type.
- *
- * Group: common
- *
- * @param eventClass the value to set
- * @return the dsl builder
- */
- default GuavaEventBusEndpointBuilder
eventClass(Class<java.lang.Object> eventClass) {
- doSetProperty("eventClass", eventClass);
- return this;
- }
- /**
- * If used on the consumer side of the route, will filter events
- * received from the EventBus to the instances of the class and
- * superclasses of eventClass. Null value of this option is equal to
- * setting it to the java.lang.Object i.e. the consumer will capture
all
- * messages incoming to the event bus. This option cannot be used
- * together with listenerInterface option.
- *
- * The option will be converted to a
- * <code>java.lang.Class<java.lang.Object></code> type.
- *
- * Group: common
- *
- * @param eventClass the value to set
- * @return the dsl builder
- */
- default GuavaEventBusEndpointBuilder eventClass(String eventClass) {
- doSetProperty("eventClass", eventClass);
- return this;
- }
- /**
- * The interface with method(s) marked with the Subscribe annotation.
- * Dynamic proxy will be created over the interface so it could be
- * registered as the EventBus listener. Particularly useful when
- * creating multi-event listeners and for handling DeadEvent properly.
- * This option cannot be used together with eventClass option.
- *
- * The option is a:
<code>java.lang.Class<java.lang.Object></code>
- * type.
- *
- * Group: common
- *
- * @param listenerInterface the value to set
- * @return the dsl builder
- */
- default GuavaEventBusEndpointBuilder
listenerInterface(Class<java.lang.Object> listenerInterface) {
- doSetProperty("listenerInterface", listenerInterface);
- return this;
- }
- /**
- * The interface with method(s) marked with the Subscribe annotation.
- * Dynamic proxy will be created over the interface so it could be
- * registered as the EventBus listener. Particularly useful when
- * creating multi-event listeners and for handling DeadEvent properly.
- * This option cannot be used together with eventClass option.
- *
- * The option will be converted to a
- * <code>java.lang.Class<java.lang.Object></code> type.
- *
- * Group: common
- *
- * @param listenerInterface the value to set
- * @return the dsl builder
- */
- default GuavaEventBusEndpointBuilder listenerInterface(String
listenerInterface) {
- doSetProperty("listenerInterface", listenerInterface);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint for the Guava EventBus component.
- */
- public interface AdvancedGuavaEventBusEndpointBuilder
- extends
- AdvancedGuavaEventBusEndpointConsumerBuilder,
- AdvancedGuavaEventBusEndpointProducerBuilder {
- default GuavaEventBusEndpointBuilder basic() {
- return (GuavaEventBusEndpointBuilder) this;
- }
-
- }
-
- public interface GuavaEventBusBuilders {
- /**
- * Guava EventBus (camel-guava-eventbus)
- * Send and receive messages to/from Guava EventBus.
- *
- * Category: messaging
- * Since: 2.10
- * Maven coordinates: org.apache.camel:camel-guava-eventbus
- *
- * Syntax: <code>guava-eventbus:eventBusRef</code>
- *
- * Path parameter: eventBusRef
- * To lookup the Guava EventBus from the registry with the given name
- *
- * @param path eventBusRef
- * @return the dsl builder
- */
- @Deprecated
- default GuavaEventBusEndpointBuilder guavaEventbus(String path) {
- return
GuavaEventBusEndpointBuilderFactory.endpointBuilder("guava-eventbus", path);
- }
- /**
- * Guava EventBus (camel-guava-eventbus)
- * Send and receive messages to/from Guava EventBus.
- *
- * Category: messaging
- * Since: 2.10
- * Maven coordinates: org.apache.camel:camel-guava-eventbus
- *
- * Syntax: <code>guava-eventbus:eventBusRef</code>
- *
- * Path parameter: eventBusRef
- * To lookup the Guava EventBus from the registry with the given name
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path eventBusRef
- * @return the dsl builder
- */
- @Deprecated
- default GuavaEventBusEndpointBuilder guavaEventbus(String
componentName, String path) {
- return
GuavaEventBusEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
-
- }
- static GuavaEventBusEndpointBuilder endpointBuilder(String componentName,
String path) {
- class GuavaEventBusEndpointBuilderImpl extends AbstractEndpointBuilder
implements GuavaEventBusEndpointBuilder, AdvancedGuavaEventBusEndpointBuilder {
- public GuavaEventBusEndpointBuilderImpl(String path) {
- super(componentName, path);
- }
- }
- return new GuavaEventBusEndpointBuilderImpl(path);
- }
-}
\ No newline at end of file
diff --git
a/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
b/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
index 563b616af132..8a7f2d7e3fbb 100644
---
a/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
+++
b/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
@@ -164,7 +164,6 @@
org.apache.camel.component.google.vision.GoogleCloudVisionComponent=camel:google
org.apache.camel.component.grape.GrapeComponent=camel:grape
org.apache.camel.component.graphql.GraphqlComponent=camel:graphql
org.apache.camel.component.grpc.GrpcComponent=camel:grpc
-org.apache.camel.component.guava.eventbus.GuavaEventBusComponent=camel:guava-eventbus
org.apache.camel.component.hashicorp.vault.HashicorpVaultComponent=camel:hashicorp-vault
org.apache.camel.component.hazelcast.atomicnumber.HazelcastAtomicnumberComponent=camel:hazelcast
org.apache.camel.component.hazelcast.instance.HazelcastInstanceComponent=camel:hazelcast
diff --git a/parent/pom.xml b/parent/pom.xml
index d6d07551baff..fa045811f2b4 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -1553,11 +1553,6 @@
<artifactId>camel-gson</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-guava-eventbus</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-hashicorp-vault</artifactId>
