[camel] 09/11: CAMEL-17571: camel-dsl - Allow to register custom annotation processors that can do custom logic after a DSL has compiled source into Java object.

[da...@apache.org]

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

davsclaus pushed a commit to branch CAMEL-17571
in repository https://gitbox.apache.org/repos/asf/camel.git

commit a612b4bdf5cfb3802b8dd3053ee410eaac9dda47
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Mar 11 22:20:04 2022 +0100

    CAMEL-17571: camel-dsl - Allow to register custom annotation processors that can do custom logic after a DSL has compiled source into Java object.
---
 .../impl/engine/CamelPostProcessorHelper.java      |   3 +-
 .../impl/CamelBeanPostProcessorInjectorTest.java   | 101 +++++++++++++++++++++
 2 files changed, 102 insertions(+), 2 deletions(-)

diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelPostProcessorHelper.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelPostProcessorHelper.java
index a6a5654..533fb49 100644
--- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelPostProcessorHelper.java
+++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelPostProcessorHelper.java
@@ -58,10 +58,9 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import static org.apache.camel.support.ObjectHelper.invokeMethod;
-import static org.apache.camel.util.ObjectHelper.isEmpty;
 
 /**
- * A helper class for Camel based injector or bean post processing hooks.
+ * A helper class for Camel based injector or bean post-processing hooks.
  */
 public class CamelPostProcessorHelper implements CamelContextAware {
 
diff --git a/core/camel-core/src/test/java/org/apache/camel/impl/CamelBeanPostProcessorInjectorTest.java b/core/camel-core/src/test/java/org/apache/camel/impl/CamelBeanPostProcessorInjectorTest.java
new file mode 100644
index 0000000..a244b3b
--- /dev/null
+++ b/core/camel-core/src/test/java/org/apache/camel/impl/CamelBeanPostProcessorInjectorTest.java
@@ -0,0 +1,101 @@
+/*
+ * 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.impl;
+
+import org.apache.camel.ContextTestSupport;
+import org.apache.camel.ExtendedCamelContext;
+import org.apache.camel.PropertyInject;
+import org.apache.camel.impl.engine.CamelPostProcessorHelper;
+import org.apache.camel.spi.CamelBeanPostProcessor;
+import org.apache.camel.spi.CamelBeanPostProcessorInjector;
+import org.apache.camel.spi.CamelLogger;
+import org.apache.camel.support.ObjectHelper;
+import org.apache.camel.util.ReflectionHelper;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import java.lang.reflect.Field;
+import java.lang.reflect.Method;
+
+public class CamelBeanPostProcessorInjectorTest extends ContextTestSupport {
+
+    private CamelBeanPostProcessor postProcessor;
+    private CamelPostProcessorHelper helper;
+
+    @Override
+    @BeforeEach
+    public void setUp() throws Exception {
+        super.setUp();
+        postProcessor = context.adapt(ExtendedCamelContext.class).getBeanPostProcessor();
+        postProcessor.addCamelBeanPostProjectInjector(new MyInjector());
+        helper = new CamelPostProcessorHelper(context);
+    }
+
+    private class MyInjector implements CamelBeanPostProcessorInjector {
+
+        @Override
+        public void onFieldInject(Field field, Object bean, String beanName) {
+            if (field.getName().equals("foo")) {
+                ReflectionHelper.setField(field, bean, "changed-foo");
+            }
+        }
+
+        @Override
+        public void onMethodInject(Method method, Object bean, String beanName) {
+            if (method.getName().equals("createLogger")) {
+                Object out = ObjectHelper.invokeMethod(method, bean, "changed-bar");
+                context.getRegistry().bind(method.getName(), out);
+            }
+        }
+    }
+
+    public class MyService {
+
+        @PropertyInject(value = "myName", defaultValue = "Donald Duck")
+        private String name;
+        @PropertyInject(value = "myFoo", defaultValue = "myDefault")
+        private String foo;
+
+        public String getName() {
+            return name;
+        }
+
+        public String getFoo() {
+            return foo;
+        }
+
+        public CamelLogger createLogger(String name) {
+            return new CamelLogger(name);
+        }
+    }
+
+    @Test
+    public void testBeanPostInjector() throws Exception {
+        MyService service = new MyService();
+
+        postProcessor.postProcessBeforeInitialization(service, "service");
+        postProcessor.postProcessAfterInitialization(service, "service");
+
+        Assertions.assertEquals("Donald Duck", service.getName());
+        Assertions.assertEquals("changed-foo", service.getFoo());
+
+        CamelLogger logger = (CamelLogger) context.getRegistry().lookupByName("createLogger");
+        Assertions.assertNotNull(logger);
+    }
+
+}