2.1.2 Logback.xml update, camel version minor update

Remove unused files
2.1.1 Added h2 storage using camel-mybatis
22 changed files with 695 additions and 202 deletions
--- a/bruno/findUser.bru
+++ b/bruno/findUser.bru
@ -0,0 +1,20 @@
+meta {
+  name: findUser
+  type: http
+  seq: 4
+}
+
+get {
+  url: http://localhost:9091/services/api/user/2
+  body: none
+  auth: basic
+}
+
+headers {
+  operationName: findUsers
+}
+
+auth:basic {
+  username: cxfrs
+  password: password
+}
--- a/bruno/findUsers.bru
+++ b/bruno/findUsers.bru
@ -5,7 +5,7 @@ meta {
 }

 get {
-  url: http://localhost:9090/services/api/user
+  url: http://localhost:9091/services/api/user
  body: none
  auth: basic
 }
--- a/bruno/updateUser.bru
+++ b/bruno/updateUser.bru
@ -5,7 +5,7 @@ meta {
 }

 post {
-  url: http://localhost:9090/services/api/user
+  url: http://localhost:9091/services/api/user
  body: json
  auth: basic
 }
@ -22,7 +22,7 @@ auth:basic {

 body:json {
  {
-    "id": 3,
-    "name": "Bruce Wayne"
-  }
+      "id": 4,
+      "name": "Diana Themyscira"
+    }
 }
--- a/conf/logback.xml
+++ b/conf/logback.xml
@ -19,9 +19,7 @@
 			<pattern>%-5level %d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %logger{36} - %msg%n</pattern>
 		</encoder>
 	</appender>
-	<logger name="org.springframework.security.ldap.userdetails" level="TRACE" /> 
-	<logger name="org.springframework.security" level="DEBUG" /> 
-	<logger name="com.example.camel" level="DEBUG" /> 
+	<logger name="com.example.sbcamel" level="DEBUG" /> 
 	<root level="INFO">
 		<appender-ref ref="STDOUT" />
 	</root>
--- a/conf/springboot.yml
+++ b/conf/springboot.yml
@ -16,4 +16,11 @@ spring:

 app:
  queue-name: "UserServiceQueue"
-
+  zookeeper:
+    url: "127.0.0.1:2181"
+    group-name: "UserServiceGroup"
+  database:
+    url: "jdbc:h2:tcp://localhost/~/h2/db/appdb"
+    username: "app"
+    password: "app"
+    mapper-package: "com.example.sbcamel.mapper"
--- a/conf2/logback.xml
+++ b/conf2/logback.xml
@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration scan="true">
+	<appender name="STDOUT"
+		class="ch.qos.logback.core.ConsoleAppender">
+		<encoder>
+			<pattern>%-5level %d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %logger{36} - %msg%n</pattern>
+		</encoder>
+	</appender>
+	<appender name="FILE"
+		class="ch.qos.logback.core.rolling.RollingFileAppender">
+		<file>logs/server.log</file>
+		<rollingPolicy
+			class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+			<fileNamePattern>logs/server.%d{yyyy-MM-dd}.log.gz</fileNamePattern>
+			<maxHistory>3</maxHistory>
+			<totalSizeCap>300MB</totalSizeCap>
+		</rollingPolicy>
+		<encoder>
+			<pattern>%-5level %d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %logger{36} - %msg%n</pattern>
+		</encoder>
+	</appender>
+	<logger name="com.example.sbcamel" level="DEBUG" /> 
+	<root level="INFO">
+		<appender-ref ref="STDOUT" />
+	</root>
+</configuration>
--- a/conf2/springboot.yml
+++ b/conf2/springboot.yml
@ -0,0 +1,26 @@
+server:
+  port: 9091
+
+camel:
+  springboot:
+    main-run-controller: true
+
+spring:
+  activemq:
+    broker-url: "tcp://localhost:61616"
+  ldap:
+    urls: ldap://localhost:10389
+    base: dc=example,dc=com
+    username: uid=admin,ou=system
+    password: secret
+
+app:
+  queue-name: "UserServiceQueue"
+  zookeeper:
+    url: "127.0.0.1:2181"
+    group-name: "UserServiceGroup"
+  database:
+    url: "jdbc:h2:tcp://localhost/~/h2/db/appdb"
+    username: "app"
+    password: "app"
+    mapper-package: "com.example.sbcamel.mapper"
--- a/db/appdb.mv.db
+++ b/db/appdb.mv.db
--- a/db/appdb.trace.db
+++ b/db/appdb.trace.db
@ -0,0 +1,105 @@
+2025-03-08 12:36:27.115360+08:00 jdbc[3]: exception
+org.h2.jdbc.JdbcSQLSyntaxErrorException: Syntax error in SQL statement "MERGE INTO [*]USER (?) VALUES (?, ?)"; expected "identifier"; SQL statement:
+MERGE INTO USER (?) VALUES (?, ?) [42001-224]
+2025-03-08 12:41:38.334685+08:00 jdbc[3]: exception
+org.h2.jdbc.JdbcSQLSyntaxErrorException: Syntax error in SQL statement "CREATE TABLE IF NOT EXISTS public.[*]user (id BIGINT not null, name CHARACTER VARYING not null, PRIMARY KEY (id))"; expected "identifier"; SQL statement:
+CREATE TABLE IF NOT EXISTS public.user (id BIGINT not null, name CHARACTER VARYING not null, PRIMARY KEY (id)) [42001-224]
+2025-03-08 12:45:24.184967+08:00 jdbc[3]: exception
+org.h2.jdbc.JdbcSQLSyntaxErrorException: Syntax error in SQL statement "MERGE INTO public.""user"" ([*]?) VALUES (?, ?)"; expected "identifier"; SQL statement:
+MERGE INTO public."user" (?) VALUES (?, ?) [42001-224]
+2025-03-08 15:26:55.471296+08:00 database: flush
+org.h2.message.DbException: General error: "org.h2.mvstore.MVStoreException: The file is locked: C:/Users/Yan/eclipse-workspace/camel-springboot-activemq6-example/db/appdb.mv.db [2.2.224/7]" [50000-224]
+	at org.h2.message.DbException.get(DbException.java:212)
+	at org.h2.message.DbException.convert(DbException.java:407)
+	at org.h2.mvstore.db.Store.lambda$new$0(Store.java:122)
+	at org.h2.mvstore.MVStore.handleException(MVStore.java:1546)
+	at org.h2.mvstore.MVStore.panic(MVStore.java:371)
+	at org.h2.mvstore.MVStore.<init>(MVStore.java:291)
+	at org.h2.mvstore.MVStore$Builder.open(MVStore.java:2035)
+	at org.h2.mvstore.db.Store.<init>(Store.java:133)
+	at org.h2.engine.Database.<init>(Database.java:326)
+	at org.h2.engine.Engine.openSession(Engine.java:92)
+	at org.h2.engine.Engine.openSession(Engine.java:222)
+	at org.h2.engine.Engine.createSession(Engine.java:201)
+	at org.h2.engine.SessionRemote.connectEmbeddedOrServer(SessionRemote.java:343)
+	at org.h2.jdbc.JdbcConnection.<init>(JdbcConnection.java:125)
+	at org.h2.Driver.connect(Driver.java:59)
+	at com.zaxxer.hikari.util.DriverDataSource.getConnection(DriverDataSource.java:137)
+	at com.zaxxer.hikari.pool.PoolBase.newConnection(PoolBase.java:360)
+	at com.zaxxer.hikari.pool.PoolBase.newPoolEntry(PoolBase.java:202)
+	at com.zaxxer.hikari.pool.HikariPool.createPoolEntry(HikariPool.java:461)
+	at com.zaxxer.hikari.pool.HikariPool.checkFailFast(HikariPool.java:550)
+	at com.zaxxer.hikari.pool.HikariPool.<init>(HikariPool.java:98)
+	at com.zaxxer.hikari.HikariDataSource.<init>(HikariDataSource.java:80)
+	at com.example.sbcamel.DatabaseConfig.dataSource(DatabaseConfig.java:69)
+	at com.example.sbcamel.DatabaseConfig$$SpringCGLIB$$0.CGLIB$dataSource$0(<generated>)
+	at com.example.sbcamel.DatabaseConfig$$SpringCGLIB$$FastClass$$1.invoke(<generated>)
+	at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:258)
+	at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:372)
+	at com.example.sbcamel.DatabaseConfig$$SpringCGLIB$$0.dataSource(<generated>)
+	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
+	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
+	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
+	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
+	at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:146)
+	at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:644)
+	at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:636)
+	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1355)
+	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1185)
+	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:562)
+	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:522)
+	at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:337)
+	at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
+	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:335)
+	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:200)
+	at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:254)
+	at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1448)
+	at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1358)
+	at org.springframework.beans.factory.support.ConstructorResolver.resolveAutowiredArgument(ConstructorResolver.java:904)
+	at org.springframework.beans.factory.support.ConstructorResolver.createArgumentArray(ConstructorResolver.java:782)
+	at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:542)
+	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1355)
+	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1185)
+	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:562)
+	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:522)
+	at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:337)
+	at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
+	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:335)
+	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:200)
+	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:313)
+	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:200)
+	at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:254)
+	at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1448)
+	at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1358)
+	at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.resolveFieldValue(AutowiredAnnotationBeanPostProcessor.java:785)
+	at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:768)
+	at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:145)
+	at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessProperties(AutowiredAnnotationBeanPostProcessor.java:509)
+	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1439)
+	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:599)
+	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:522)
+	at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:337)
+	at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
+	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:335)
+	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:200)
+	at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:975)
+	at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:971)
+	at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:625)
+	at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:146)
+	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:754)
+	at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:456)
+	at org.springframework.boot.SpringApplication.run(SpringApplication.java:335)
+	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1363)
+	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1352)
+	at com.example.sbcamel.Boot.main(Boot.java:27)
+Caused by: org.h2.jdbc.JdbcSQLNonTransientException: General error: "org.h2.mvstore.MVStoreException: The file is locked: C:/Users/Yan/eclipse-workspace/camel-springboot-activemq6-example/db/appdb.mv.db [2.2.224/7]" [50000-224]
+	at org.h2.message.DbException.getJdbcSQLException(DbException.java:566)
+	at org.h2.message.DbException.getJdbcSQLException(DbException.java:489)
+	... 83 more
+Caused by: org.h2.mvstore.MVStoreException: The file is locked: C:/Users/Yan/eclipse-workspace/camel-springboot-activemq6-example/db/appdb.mv.db [2.2.224/7]
+	at org.h2.mvstore.DataUtils.newMVStoreException(DataUtils.java:996)
+	at org.h2.mvstore.SingleFileStore.lockFileChannel(SingleFileStore.java:143)
+	at org.h2.mvstore.SingleFileStore.open(SingleFileStore.java:117)
+	at org.h2.mvstore.SingleFileStore.open(SingleFileStore.java:81)
+	at org.h2.mvstore.MVStore.<init>(MVStore.java:286)
+	... 77 more
--- a/pom.xml
+++ b/pom.xml
@ -4,19 +4,21 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>com.example</groupId>
 	<artifactId>camel-springboot-activemq6-example</artifactId>
-	<version>2.0.1</version>
+	<version>2.1.2</version>
 	<name>camel-springboot-activemq6-example</name>
 	<parent>
 		<groupId>org.springframework.boot</groupId>
 		<artifactId>spring-boot-starter-parent</artifactId>
-		<version>3.3.8</version>
+		<version>3.3.9</version>
 	</parent>
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<maven.compiler.source>17</maven.compiler.source>
 		<maven.compiler.target>17</maven.compiler.target>
-		<camel.version>4.8.3</camel.version>
+		<camel.version>4.8.4</camel.version>
 		<springboot.version>${project.parent.version}</springboot.version>
+		<mybatis.version>3.5.19</mybatis.version>
+		<mybatis-spring.version>3.0.4</mybatis-spring.version>
 	</properties>

 	<dependencyManagement>
@ -56,6 +58,10 @@
 			<groupId>org.springframework.security</groupId>
 			<artifactId>spring-security-ldap</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-jdbc</artifactId>
+		</dependency>
 		<!-- Camel -->
 		<dependency>
 			<groupId>org.apache.camel.springboot</groupId>
@ -81,6 +87,33 @@
 			<groupId>org.apache.camel.springboot</groupId>
 			<artifactId>camel-jackson-starter</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.apache.camel.springboot</groupId>
+			<artifactId>camel-zookeeper-master-starter</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.camel.springboot</groupId>
+			<artifactId>camel-mybatis-starter</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>com.h2database</groupId>
+			<artifactId>h2</artifactId>
+			<scope>runtime</scope>
+		</dependency>
+		<dependency>
+			<groupId>com.zaxxer</groupId>
+			<artifactId>HikariCP</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.mybatis</groupId>
+			<artifactId>mybatis</artifactId>
+			<version>${mybatis.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.mybatis</groupId>
+			<artifactId>mybatis-spring</artifactId>
+			<version>${mybatis-spring.version}</version>
+		</dependency>
 		<dependency>
 			<groupId>com.fasterxml.jackson.jakarta.rs</groupId>
 			<artifactId>jackson-jakarta-rs-json-provider</artifactId>
@ -100,7 +133,7 @@
 				<groupId>org.springframework.boot</groupId>
 				<artifactId>spring-boot-maven-plugin</artifactId>
 				<configuration>
-					<mainClass>com.example.camel.Boot</mainClass>
+					<mainClass>com.example.sbcamel.Boot</mainClass>
 				</configuration>
 				<executions>
 					<execution>
--- a/readme.md
+++ b/readme.md
@ -1,13 +1,20 @@
-**Please start the following services before testing**
+## Setup 

-1. ApacheDS Server 2.0.0.AM27
+1. Please start the following services before testing :

-2. Apache ActiveMQ 6.1.5
+```
+  ApacheDS Server 2.0.0.AM27
+  Apache ActiveMQ 6.1.5
+  Apache Zookeeper 3.9.3
+  H2 Database Version 2.3.232
+```

+2. Please see conf/springboot.yml for LDAP/ActiveMQ Address
+3. For LDAP group and user setup, see misc/ldapdb.ldif

-**Startup screens**
+## Startup screens 

-1. ApacheDS Server 2.0.0.AM27
+**1. ApacheDS Server 2.0.0.AM27**

 ```
 C:\Users\XXX\apacheds-2.0.0.AM28-SNAPSHOT\bin>apacheds.bat default start
@ -41,7 +48,7 @@ Starting ApacheDS instance 'default'...

 ```

-2. Apache ActiveMQ 6.1.5
+**2. Apache ActiveMQ 6.1.5**

 ```
 C:\Users\XXX\apache-activemq-6.1.5\bin>activemq start
@ -89,10 +96,128 @@ Loading message broker from: xbean:activemq.xml
 INFO | ActiveMQ Jolokia REST API available at http://127.0.0.1:8161/api/jolokia/
 ```

-**Setup**
+**3. Apache Zookeeper 3.9.3**
+
+```
+C:\Users\XXX\apache-zookeeper-3.9.3-bin>bin\zkServer.cmd
+
+C:\Users\XXX\apache-zookeeper-3.9.3-bin>call "C:\Users\XXX\graalvm-jdk-17.0.14+8.1"\bin\java "-Dzookeeper.log.dir=C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\logs" "-Dzookeeper.log.file=zookeeper-XXX-server-DESKTOP-66E87L5.log" "-XX:+HeapDumpOnOutOfMemoryError" "-XX:OnOutOfMemoryError=cmd /c taskkill /pid %%p /t /f" -cp "C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\build\classes;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\build\lib\*;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\*;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\*;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\conf" org.apache.zookeeper.server.quorum.QuorumPeerMain "C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\conf\zoo.cfg"
+2025-03-01 15:15:37,456 [myid:] - INFO  [main:o.a.z.s.q.QuorumPeerConfig@177] - Reading configuration from: C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\conf\zoo.cfg
+2025-03-01 15:15:37,458 [myid:] - WARN  [main:o.a.z.s.u.VerifyingFileFactory@65] - data is relative. Prepend .\ to indicate that you're sure!
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.q.QuorumPeerConfig@440] - clientPortAddress is 0.0.0.0:2181
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.q.QuorumPeerConfig@444] - secureClientPort is not set
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.q.QuorumPeerConfig@460] - observerMasterPort is not set
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.q.QuorumPeerConfig@477] - metricsProvider.className is org.apache.zookeeper.metrics.impl.DefaultMetricsProvider
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.DatadirCleanupManager@78] - autopurge.snapRetainCount set to 3
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.DatadirCleanupManager@79] - autopurge.purgeInterval set to 0
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.DatadirCleanupManager@101] - Purge task is not scheduled.
+2025-03-01 15:15:37,460 [myid:] - WARN  [main:o.a.z.s.q.QuorumPeerMain@139] - Either no config or no quorum defined in config, running in standalone mode
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.j.ManagedUtil@46] - Log4j 1.2 jmx support not found; jmx disabled.
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.q.QuorumPeerConfig@177] - Reading configuration from: C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\conf\zoo.cfg
+2025-03-01 15:15:37,460 [myid:] - WARN  [main:o.a.z.s.u.VerifyingFileFactory@65] - data is relative. Prepend .\ to indicate that you're sure!
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.q.QuorumPeerConfig@440] - clientPortAddress is 0.0.0.0:2181
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.q.QuorumPeerConfig@444] - secureClientPort is not set
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.q.QuorumPeerConfig@460] - observerMasterPort is not set
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.q.QuorumPeerConfig@477] - metricsProvider.className is org.apache.zookeeper.metrics.impl.DefaultMetricsProvider
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServerMain@123] - Starting server
+2025-03-01 15:15:37,460 [myid:] - INFO  [main:o.a.z.s.ServerMetrics@64] - ServerMetrics initialized with provider org.apache.zookeeper.metrics.impl.DefaultMetricsProvider@4c762604
+2025-03-01 15:15:37,478 [myid:] - INFO  [main:o.a.z.s.a.DigestAuthenticationProvider@51] - ACL digest algorithm is: SHA1
+2025-03-01 15:15:37,481 [myid:] - INFO  [main:o.a.z.s.a.DigestAuthenticationProvider@65] - zookeeper.DigestAuthenticationProvider.enabled = true
+2025-03-01 15:15:37,481 [myid:] - INFO  [main:o.a.z.s.p.FileTxnSnapLog@124] - zookeeper.snapshot.trust.empty : false
+2025-03-01 15:15:37,481 [myid:] - INFO  [main:o.a.z.ZookeeperBanner@42] -
+2025-03-01 15:15:37,481 [myid:] - INFO  [main:o.a.z.ZookeeperBanner@42] -   ______                  _
+2025-03-01 15:15:37,481 [myid:] - INFO  [main:o.a.z.ZookeeperBanner@42] -  |___  /                 | |
+2025-03-01 15:15:37,481 [myid:] - INFO  [main:o.a.z.ZookeeperBanner@42] -     / /    ___     ___   | | __   ___    ___   _ __     ___   _ __
+2025-03-01 15:15:37,481 [myid:] - INFO  [main:o.a.z.ZookeeperBanner@42] -    / /    / _ \   / _ \  | |/ /  / _ \  / _ \ | '_ \   / _ \ | '__|
+2025-03-01 15:15:37,481 [myid:] - INFO  [main:o.a.z.ZookeeperBanner@42] -   / /__  | (_) | | (_) | |   <  |  __/ |  __/ | |_) | |  __/ | |
+2025-03-01 15:15:37,481 [myid:] - INFO  [main:o.a.z.ZookeeperBanner@42] -  /_____|  \___/   \___/  |_|\_\  \___|  \___| | .__/   \___| |_|
+2025-03-01 15:15:37,481 [myid:] - INFO  [main:o.a.z.ZookeeperBanner@42] -                                               | |
+2025-03-01 15:15:37,481 [myid:] - INFO  [main:o.a.z.ZookeeperBanner@42] -                                               |_|
+2025-03-01 15:15:37,481 [myid:] - INFO  [main:o.a.z.ZookeeperBanner@42] -
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:zookeeper.version=3.9.3-c26634f34490bb0ea7a09cc51e05ede3b4e320ee, built on 2024-10-17 23:21 UTC
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:host.name=DESKTOP-66E87L5
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:java.version=17.0.14
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:java.vendor=Oracle Corporation
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:java.home=C:\Users\XXX\graalvm-jdk-17.0.14+8.1
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:java.class.path=C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\build\classes;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\build\lib\*;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\*;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\audience-annotations-0.12.0.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\commons-cli-1.5.0.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\commons-io-2.17.0.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\jackson-annotations-2.15.2.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\jackson-core-2.15.2.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\jackson-databind-2.15.2.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\javax.servlet-api-3.1.0.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\jetty-http-9.4.56.v20240826.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\jetty-io-9.4.56.v20240826.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\jetty-security-9.4.56.v20240826.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\jetty-server-9.4.56.v20240826.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\jetty-servlet-9.4.56.v20240826.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\jetty-util-9.4.56.v20240826.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\jetty-util-ajax-9.4.56.v20240826.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\jline-2.14.6.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\logback-classic-1.2.13.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\logback-core-1.2.13.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\metrics-core-4.1.12.1.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-buffer-4.1.113.Final.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-codec-4.1.113.Final.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-common-4.1.113.Final.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-handler-4.1.113.Final.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-resolver-4.1.113.Final.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-tcnative-boringssl-static-2.0.66.Final-linux-aarch_64.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-tcnative-boringssl-static-2.0.66.Final-linux-x86_64.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-tcnative-boringssl-static-2.0.66.Final-osx-aarch_64.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-tcnative-boringssl-static-2.0.66.Final-osx-x86_64.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-tcnative-boringssl-static-2.0.66.Final-windows-x86_64.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-tcnative-boringssl-static-2.0.66.Final.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-tcnative-classes-2.0.66.Final.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-transport-4.1.113.Final.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-transport-classes-epoll-4.1.113.Final.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-transport-native-epoll-4.1.113.Final-linux-x86_64.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\netty-transport-native-unix-common-4.1.113.Final.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\simpleclient-0.9.0.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\simpleclient_common-0.9.0.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\simpleclient_hotspot-0.9.0.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\simpleclient_servlet-0.9.0.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\slf4j-api-1.7.30.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\snappy-java-1.1.10.5.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\zookeeper-3.9.3.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\zookeeper-jute-3.9.3.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\lib\zookeeper-prometheus-metrics-3.9.3.jar;C:\Users\XXX\apache-zookeeper-3.9.3-bin\bin\..\conf
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:java.library.path=C:\Users\XXX\graalvm-jdk-17.0.14+8.1\bin;C:\WINDOWS\Sun\Java\bin;C:\WINDOWS\system32;C:\WINDOWS;C:\WINDOWS\system32;C:\WINDOWS;C:\WINDOWS\System32\Wbem;C:\WINDOWS\System32\WindowsPowerShell\v1.0\;C:\WINDOWS\System32\OpenSSH\;C:\Program Files (x86)\NVIDIA Corporation\PhysX\Common;C:\Program Files\NVIDIA Corporation\NVIDIA NvDLISR;C:\Program Files\PuTTY\;C:\Users\XXX\AppData\Local\Microsoft\WindowsApps;C:\Users\XXX\graalvm-jdk-17.0.14+8.1\bin;;C:\Users\XXX\graalvm-jdk-17.0.14+8.1\bin;.
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:java.io.tmpdir=C:\Users\XXX\AppData\Local\Temp\
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:java.compiler=<NA>
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:os.name=Windows 11
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:os.arch=amd64
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:os.version=10.0
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:user.name=XXX
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:user.home=C:\Users\XXX
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:user.dir=C:\Users\XXX\apache-zookeeper-3.9.3-bin
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:os.memory.free=495MB
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:os.memory.max=8136MB
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.Environment@98] - Server environment:os.memory.total=512MB
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@149] - zookeeper.enableEagerACLCheck = false
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@162] - zookeeper.digest.enabled = true
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@166] - zookeeper.closeSessionTxn.enabled = true
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@2242] - zookeeper.serializeLastProcessedZxid.enabled = true
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@1585] - zookeeper.flushDelay = 0 ms
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@1594] - zookeeper.maxWriteQueuePollTime = 0 ms
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@1603] - zookeeper.maxBatchSize=1000
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@287] - zookeeper.intBufferStartingSizeBytes = 1024
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.BlueThrottle@141] - Weighed connection throttling is disabled
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.AuthenticationHelper@66] - zookeeper.enforce.auth.enabled = false
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.AuthenticationHelper@67] - zookeeper.enforce.auth.schemes = []
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@1395] - minSessionTimeout set to 4000 ms
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@1404] - maxSessionTimeout set to 40000 ms
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ResponseCache@45] - getData response cache size is initialized with value 400.
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ResponseCache@45] - getChildren response cache size is initialized with value 400.
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.u.RequestPathMetricsCollector@109] - zookeeper.pathStats.slotCapacity = 60
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.u.RequestPathMetricsCollector@110] - zookeeper.pathStats.slotDuration = 15
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.u.RequestPathMetricsCollector@111] - zookeeper.pathStats.maxDepth = 6
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.u.RequestPathMetricsCollector@112] - zookeeper.pathStats.initialDelay = 5
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.u.RequestPathMetricsCollector@113] - zookeeper.pathStats.delay = 5
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.u.RequestPathMetricsCollector@114] - zookeeper.pathStats.enabled = false
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@1622] - The max bytes for all large requests are set to 104857600
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@1636] - The large request threshold is set to -1
+2025-03-01 15:15:37,492 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@385] - Created server with tickTime 2000 ms minSessionTimeout 4000 ms maxSessionTimeout 40000 ms clientPortListenBacklog -1 dataLogdir data\version-2 snapdir data\version-2
+2025-03-01 15:15:37,513 [myid:] - INFO  [main:o.e.j.u.l.Log@170] - Logging initialized @220ms to org.eclipse.jetty.util.log.Slf4jLog
+2025-03-01 15:15:37,545 [myid:] - WARN  [main:o.e.j.s.h.ContextHandler@1662] - o.e.j.s.ServletContextHandler@6cf0e0ba{/,null,STOPPED} contextPath ends with /*
+2025-03-01 15:15:37,545 [myid:] - WARN  [main:o.e.j.s.h.ContextHandler@1673] - Empty contextPath
+2025-03-01 15:15:37,556 [myid:] - INFO  [main:o.e.j.s.Server@375] - jetty-9.4.56.v20240826; built: 2024-08-26T17:15:05.868Z; git: ec6782ff5ead824dabdcf47fa98f90a4aedff401; jvm 17.0.14+8-LTS-jvmci-23.0-b54
+2025-03-01 15:15:37,570 [myid:] - INFO  [main:o.e.j.s.s.DefaultSessionIdManager@334] - DefaultSessionIdManager workerName=node0
+2025-03-01 15:15:37,570 [myid:] - INFO  [main:o.e.j.s.s.DefaultSessionIdManager@339] - No SessionScavenger set, using defaults
+2025-03-01 15:15:37,570 [myid:] - INFO  [main:o.e.j.s.s.HouseKeeper@132] - node0 Scavenging every 660000ms
+2025-03-01 15:15:37,570 [myid:] - WARN  [main:o.e.j.s.ConstraintSecurityHandler@759] - ServletContext@o.e.j.s.ServletContextHandler@6cf0e0ba{/,null,STARTING} has uncovered http methods for path: /*
+2025-03-01 15:15:37,583 [myid:] - INFO  [main:o.e.j.s.h.ContextHandler@921] - Started o.e.j.s.ServletContextHandler@6cf0e0ba{/,null,AVAILABLE}
+2025-03-01 15:15:37,647 [myid:] - INFO  [main:o.e.j.s.AbstractConnector@333] - Started ServerConnector@3c407114{HTTP/1.1, (http/1.1)}{0.0.0.0:8080}
+2025-03-01 15:15:37,647 [myid:] - INFO  [main:o.e.j.s.Server@415] - Started @352ms
+2025-03-01 15:15:37,647 [myid:] - INFO  [main:o.a.z.s.a.JettyAdminServer@201] - Started AdminServer on address 0.0.0.0, port 8080 and command URL /commands
+2025-03-01 15:15:37,649 [myid:] - INFO  [main:o.a.z.s.ServerCnxnFactory@172] - Using org.apache.zookeeper.server.NIOServerCnxnFactory as server connection factory
+2025-03-01 15:15:37,649 [myid:] - WARN  [main:o.a.z.s.ServerCnxnFactory@337] - maxCnxns is not configured, using default value 0.
+2025-03-01 15:15:37,649 [myid:] - INFO  [main:o.a.z.s.NIOServerCnxnFactory@652] - Configuring NIO connection handler with 10s sessionless connection timeout, 3 selector thread(s), 56 worker threads, and 64 kB direct buffers.
+2025-03-01 15:15:37,649 [myid:] - INFO  [main:o.a.z.s.NIOServerCnxnFactory@660] - binding to port 0.0.0.0/0.0.0.0:2181
+2025-03-01 15:15:37,659 [myid:] - INFO  [main:o.a.z.s.w.WatchManagerFactory@42] - Using org.apache.zookeeper.server.watch.WatchManager as watch manager
+2025-03-01 15:15:37,660 [myid:] - INFO  [main:o.a.z.s.w.WatchManagerFactory@42] - Using org.apache.zookeeper.server.watch.WatchManager as watch manager
+2025-03-01 15:15:37,660 [myid:] - INFO  [main:o.a.z.s.ZKDatabase@134] - zookeeper.snapshotSizeFactor = 0.33
+2025-03-01 15:15:37,660 [myid:] - INFO  [main:o.a.z.s.ZKDatabase@154] - zookeeper.commitLogCount=500
+2025-03-01 15:15:37,664 [myid:] - INFO  [main:o.a.z.s.p.SnapStream@61] - zookeeper.snapshot.compression.method = CHECKED
+2025-03-01 15:15:37,664 [myid:] - INFO  [main:o.a.z.s.p.FileTxnSnapLog@480] - Snapshotting: 0x0 to data\version-2\snapshot.0
+2025-03-01 15:15:37,665 [myid:] - INFO  [main:o.a.z.s.ZKDatabase@291] - Snapshot loaded in 5 ms, highest zxid is 0x0, digest is 1371985504
+2025-03-01 15:15:37,666 [myid:] - INFO  [main:o.a.z.s.p.FileTxnSnapLog@480] - Snapshotting: 0x0 to data\version-2\snapshot.0
+2025-03-01 15:15:37,667 [myid:] - INFO  [main:o.a.z.s.ZooKeeperServer@589] - Snapshot taken in 0 ms
+2025-03-01 15:15:37,670 [myid:] - INFO  [ProcessThread(sid:0 cport:2181)::o.a.z.s.PrepRequestProcessor@138] - PrepRequestProcessor (sid:0) started, reconfigEnabled=false
+2025-03-01 15:15:37,670 [myid:] - INFO  [main:o.a.z.s.RequestThrottler@75] - zookeeper.request_throttler.shutdownTimeout = 10000 ms
+2025-03-01 15:15:37,719 [myid:] - INFO  [main:o.a.z.s.ContainerManager@83] - Using checkIntervalMs=60000 maxPerMinute=10000 maxNeverUsedIntervalMs=0
+2025-03-01 15:15:37,720 [myid:] - INFO  [main:o.a.z.a.ZKAuditProvider@42] - ZooKeeper audit is disabled.
+2025-03-01 15:28:22,213 [myid:] - INFO  [SyncThread:0:o.a.z.s.p.FileTxnLog@291] - Creating new log file: log.1
+```
+
+**4. H2 Database Version 2.3.232**

-* Please see conf/springboot.yml for LDAP/ActiveMQ Address
+```
+C:\Users\XXX\Desktop>SET JAVA_HOME=C:\Users\XXX\graalvm-jdk-17.0.14+8.1

-* For LDAP group and user setup, see misc/ldapdb.ldif
+C:\Users\XXX\Desktop>SET PATH=C:\WINDOWS\system32;C:\WINDOWS;C:\WINDOWS\System32\Wbem;C:\WINDOWS\System32\WindowsPowerShell\v1.0\;C:\WINDOWS\System32\OpenSSH\;C:\Program Files (x86)\NVIDIA Corporation\PhysX\Common;C:\Program Files\NVIDIA Corporation\NVIDIA NvDLISR;C:\Program Files\PuTTY\;C:\Users\XXX\AppData\Local\Microsoft\WindowsApps;C:\Users\XXX\graalvm-jdk-17.0.14+8.1\bin;;C:\Users\XXX\graalvm-jdk-17.0.14+8.1\bin

+C:\Users\XXX\Desktop>cd C:\Users\XXX\h2\bin

+C:\Users\XXX\h2\bin>h2.bat -tcp -web
+Web Console server running at http://127.0.0.1:8082?key=8c2f1bfb9fb08604f1e3a7849e8b338514438c2c729b87ecc98108b6102818c6 (only local connections)
+TCP server running at tcp://127.0.0.1:9092 (only local connections)
+```
--- a/src/main/java/com/example/camel/CamelRouter.java
+++ b/src/main/java/com/example/camel/CamelRouter.java
@ -1,34 +0,0 @@
-package com.example.camel;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.bean.validator.BeanValidationException;
-import org.apache.camel.model.dataformat.JsonLibrary;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.stereotype.Component;
-
-import jakarta.ws.rs.core.Response;
-
-@Component
-public class CamelRouter extends RouteBuilder {
-
-	@Value("${app.queue-name}")
-	private String queueName;
-
-	@Override
-	public void configure() throws Exception {
-		// very raw way, just to handle the validation responses
-		onException(BeanValidationException.class).handled(true)
-				.setHeader(Exchange.HTTP_RESPONSE_CODE, constant(Response.Status.BAD_REQUEST.getStatusCode()))
-				.setBody(simple("${exchangeProperty.CamelExceptionCaught.getMessage()}"));
-
-		from("cxfrs:/api?resourceClasses=" + UserService.class.getName() + "&bindingStyle=SimpleConsumer"
-				+ "&providers=jaxrsProvider&loggingFeatureEnabled=true").to("log:cxfrs-log?showAll=true")
-				.setHeader(Exchange.BEAN_METHOD_NAME, simple("${header.operationName}"))
-				.to("activemq6:queue:" + queueName);
-
-		from("activemq6:queue:" + queueName).to("bean-validator:user").bean(UserServiceImpl.class).marshal()
-				.json(JsonLibrary.Jackson);
-	}
-
-}
--- a/src/main/java/com/example/camel/User.java
+++ b/src/main/java/com/example/camel/User.java
@ -1,54 +0,0 @@
-package com.example.camel;
-
-import java.io.Serializable;
-import java.util.StringJoiner;
-
-import jakarta.validation.constraints.NotNull;
-import jakarta.validation.constraints.Size;
-
-/**
- * User entity
- *
- */
-@SuppressWarnings("serial")
-public class User implements Serializable {
-
-    @NotNull(message = "custom message")
-    private Integer id;
-
-    @NotNull
-    @Size(min = 3, max = 20)
-    private String name;
-
-    public User() {
-    }
-
-    public User(Integer id, String name) {
-        this.id = id;
-        this.name = name;
-    }
-
-    public Integer getId() {
-        return id;
-    }
-
-    public void setId(Integer id) {
-        this.id = id;
-    }
-
-    public String getName() {
-        return name;
-    }
-
-    public void setName(String name) {
-        this.name = name;
-    }
-
-    @Override
-    public String toString() {
-        return new StringJoiner(", ", User.class.getSimpleName() + "[", "]")
-                .add("id=" + id)
-                .add("name='" + name + "'")
-                .toString();
-    }
-}
--- a/src/main/java/com/example/camel/UserService.java
+++ b/src/main/java/com/example/camel/UserService.java
@ -1,52 +0,0 @@
-package com.example.camel;
-
-import java.util.Collection;
-
-import jakarta.validation.Valid;
-import jakarta.ws.rs.Consumes;
-import jakarta.ws.rs.GET;
-import jakarta.ws.rs.POST;
-import jakarta.ws.rs.Path;
-import jakarta.ws.rs.PathParam;
-import jakarta.ws.rs.Produces;
-import jakarta.ws.rs.core.MediaType;
-
-/**
- * Service interface for managing users.
- */
-public interface UserService {
-
-    /**
-     * Find a user by the given ID
-     *
-     * @param id
-     *            the ID of the user
-     * @return the user, or <code>null</code> if user not found.
-     */
-    @GET
-    @Path("/user/{id}")
-    @Produces(MediaType.APPLICATION_JSON)
-    User findUser(@PathParam("id") Integer id);
-
-    /**
-     * Find all users
-     *
-     * @return a collection of all users
-     */
-    @GET
-    @Path("/user")
-    @Produces(MediaType.APPLICATION_JSON)
-    Collection<User> findUsers();
-
-    /**
-     * Update the given user
-     *
-     * @param user
-     *            the user
-     */
-    @POST
-    @Path("/user")
-    @Consumes(MediaType.APPLICATION_JSON)
-    User updateUser(@Valid User user);
-
-}
--- a/src/main/java/com/example/camel/UserServiceImpl.java
+++ b/src/main/java/com/example/camel/UserServiceImpl.java
@ -1,33 +0,0 @@
-package com.example.camel;
-
-import java.util.Collection;
-import java.util.Map;
-import java.util.TreeMap;
-
-public class UserServiceImpl implements UserService {
-
-    private final Map<Integer, User> users = new TreeMap<>();
-
-    public UserServiceImpl() {
-        users.put(1, new User(1, "John Coltrane"));
-        users.put(2, new User(2, "Miles Davis"));
-        users.put(3, new User(3, "Sonny Rollins"));
-    }
-
-    @Override
-    public User findUser(Integer id) {
-        return users.get(id);
-    }
-
-    @Override
-    public Collection<User> findUsers() {
-        return users.values();
-    }
-
-    @Override
-    public User updateUser(User user) {
-        users.put(user.getId(), user);
-        return user;
-    }
-
-}
--- a/src/main/java/com/example/sbcamel/Boot.java
+++ b/src/main/java/com/example/sbcamel/Boot.java
@ -1,4 +1,4 @@
-package com.example.camel;
+package com.example.sbcamel;

 import java.io.File;

@ -18,12 +18,12 @@ public class Boot {
 			configDirectory = args[0];
 		}
 		logger.info("config directory: {}", configDirectory);
-		
+
 		if (new File(configDirectory).exists() && new File(configDirectory).isDirectory()) {
 			System.setProperty("spring.config.location", configDirectory + "/springboot.yml");
 			System.setProperty("logging.config", configDirectory + "/logback.xml");
 		}
-		System.setProperty("org.apache.activemq.SERIALIZABLE_PACKAGES","*");
+		System.setProperty("org.apache.activemq.SERIALIZABLE_PACKAGES", "*");
 		SpringApplication.run(Boot.class, args);
 	}

--- a/src/main/java/com/example/sbcamel/CamelRouter.java
+++ b/src/main/java/com/example/sbcamel/CamelRouter.java
@ -0,0 +1,81 @@
+package com.example.sbcamel;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.bean.BeanConstants;
+import org.apache.camel.component.bean.validator.BeanValidationException;
+import org.apache.camel.component.cxf.common.message.CxfConstants;
+import org.apache.camel.component.zookeepermaster.policy.MasterRoutePolicy;
+import org.apache.camel.model.dataformat.JsonLibrary;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Component;
+
+import jakarta.annotation.PostConstruct;
+import jakarta.ws.rs.core.Response;
+
+@Component
+public class CamelRouter extends RouteBuilder {
+	private static final String createUserSql = "CREATE TABLE IF NOT EXISTS public.\"user\" (id BIGINT not null, "
+			+ "name CHARACTER VARYING not null, PRIMARY KEY (id))";
+
+	@Value("${app.queue-name}")
+	private String queueName;
+
+	@Value("${app.zookeeper.url}")
+	private String zookeeperUrl;
+
+	@Value("${app.zookeeper.group-name}")
+	private String groupName;
+
+	@Autowired
+	private JdbcTemplate jdbcTemplate;
+
+	@PostConstruct
+	private void init() {
+		org.apache.ibatis.logging.LogFactory.useSlf4jLogging();
+		jdbcTemplate.execute(createUserSql);
+	}
+
+	@Override
+	public void configure() throws Exception {
+		// very raw way, just to handle the validation responses
+		onException(BeanValidationException.class).handled(true)
+				.setHeader(Exchange.HTTP_RESPONSE_CODE, constant(Response.Status.BAD_REQUEST.getStatusCode()))
+				.setBody(simple("${exchangeProperty.CamelExceptionCaught.getMessage()}"));
+
+		onException(jakarta.ws.rs.NotFoundException.class).handled(true)
+				.setHeader(Exchange.HTTP_RESPONSE_CODE, constant(Response.Status.NOT_FOUND.getStatusCode()))
+				.setBody(simple("${exchangeProperty.CamelExceptionCaught.getMessage()}"));
+
+		from("cxfrs:/api?resourceClasses=" + UserService.class.getName() + "&bindingStyle=Default"
+				+ "&providers=jaxrsProvider&loggingFeatureEnabled=true").to("log:cxfrs?showAll=true")
+				.to("bean-validator:user").to("activemq6:queue:" + queueName).process(exchange -> {
+					if (exchange.getMessage().getBody() != null && exchange.getMessage().getBody() instanceof byte[]
+							&& new String((byte[]) exchange.getMessage().getBody()).equals("null")) {
+						if (exchange.getIn().getHeader(Exchange.HTTP_METHOD).equals("GET")) {
+							throw new jakarta.ws.rs.NotFoundException();
+						}
+					}
+				});
+
+		MasterRoutePolicy masterRoutePolicy = new MasterRoutePolicy();
+		masterRoutePolicy.setZooKeeperUrl(zookeeperUrl);
+		masterRoutePolicy.setGroupName(groupName);
+
+		from("activemq6:queue:" + queueName).autoStartup("false").routePolicy(masterRoutePolicy)
+				.process(exchange -> exchange.getIn().setHeader(BeanConstants.BEAN_METHOD_NAME,
+						exchange.getIn().getHeader(CxfConstants.OPERATION_NAME.toLowerCase())))
+				.to("log:activemq?showAll=true").transacted("propagationRequired").choice()
+				.when(header(BeanConstants.BEAN_METHOD_NAME).isEqualTo("updateUser"))
+				.to("mybatis:com.example.sbcamel.mapper.UserMapper.updateUser?statementType=Update")
+				.when(header(BeanConstants.BEAN_METHOD_NAME).isEqualTo("findUsers"))
+				.to("mybatis:com.example.sbcamel.mapper.UserMapper.findUsers?statementType=SelectList")
+				.when(header(BeanConstants.BEAN_METHOD_NAME).isEqualTo("findUser"))
+				.to("mybatis:com.example.sbcamel.mapper.UserMapper.findUser?statementType=SelectOne")
+				.end().marshal().json(JsonLibrary.Jackson);
+	}
+
+}
--- a/src/main/java/com/example/sbcamel/DatabaseConfig.java
+++ b/src/main/java/com/example/sbcamel/DatabaseConfig.java
@ -0,0 +1,120 @@
+package com.example.sbcamel;
+
+import java.io.IOException;
+import java.util.Objects;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+import javax.sql.DataSource;
+
+import org.apache.camel.component.mybatis.MyBatisComponent;
+import org.apache.camel.spring.spi.SpringTransactionPolicy;
+import org.apache.ibatis.mapping.Environment;
+import org.apache.ibatis.session.SqlSessionFactory;
+import org.apache.ibatis.session.SqlSessionFactoryBuilder;
+import org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+import org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy;
+import org.springframework.transaction.PlatformTransactionManager;
+
+import com.google.common.reflect.ClassPath;
+import com.zaxxer.hikari.HikariConfig;
+import com.zaxxer.hikari.HikariDataSource;
+
+@Configuration
+public class DatabaseConfig {
+
+	private static final Logger logger = LoggerFactory.getLogger(DatabaseConfig.class);
+
+	public static final String CFG_APP_DATABASE_URL = "${app.database.url}";
+	public static final String CFG_APP_DATABASE_USERNAME = "${app.database.username:}";
+	public static final String CFG_APP_DATABASE_PASSWORD = "${app.database.password:}";
+	public static final String CFG_APP_DATABASE_MAPPER_PACKAGE = "${app.database.mapper-package}";
+	public static final String CFG_APP_DATABASE_SPRINGBOOT_CLASS_PREFIX = "${app.database.springboot-class-prefix:BOOT-INF.classes.}";
+
+	@Value(CFG_APP_DATABASE_URL)
+	private String dbUrl;
+
+	@Value(CFG_APP_DATABASE_USERNAME)
+	private String dbUsername;
+
+	@Value(CFG_APP_DATABASE_PASSWORD)
+	private String dbPassword;
+
+	@Value(CFG_APP_DATABASE_MAPPER_PACKAGE)
+	private String mapperPackage;
+
+	@Value(CFG_APP_DATABASE_SPRINGBOOT_CLASS_PREFIX)
+	private String springBootClassPrefix;
+
+	@Bean
+	HikariConfig hikariConfig() {
+		HikariConfig config = new HikariConfig();
+		config.setJdbcUrl(dbUrl);
+		config.setUsername(dbUsername);
+		config.setPassword(dbPassword);
+		config.addDataSourceProperty("cachePrepStmts", "true");
+		config.addDataSourceProperty("prepStmtCacheSize", "250");
+		config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048");
+		return config;
+	}
+
+	@Bean
+	DataSource dataSource(HikariConfig hikariConfig) {
+		return new TransactionAwareDataSourceProxy(new HikariDataSource(hikariConfig));
+	}
+
+	@Bean
+	PlatformTransactionManager txManager(DataSource dataSource) {
+		return new DataSourceTransactionManager(dataSource);
+	}
+
+	@Bean
+	SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {
+		Environment environment = new Environment("development", new JdbcTransactionFactory(), dataSource);
+		org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration(
+				environment);
+		Set<Class<?>> mapperClasses = findAllClassesUsingGuava(mapperPackage);
+		mapperClasses.forEach(configuration::addMapper);
+		return new SqlSessionFactoryBuilder().build(configuration);
+	}
+
+	@Bean
+	MyBatisComponent mybatis(SqlSessionFactory sqlSessionFactory) {
+		MyBatisComponent mybatis = new MyBatisComponent();
+		mybatis.setSqlSessionFactory(sqlSessionFactory);
+		return mybatis;
+	}
+
+	@Bean
+	SpringTransactionPolicy propagationRequired(PlatformTransactionManager txManager) {
+		SpringTransactionPolicy propagationRequired = new SpringTransactionPolicy();
+		propagationRequired.setTransactionManager(txManager);
+		propagationRequired.setPropagationBehaviorName("PROPAGATION_REQUIRED");
+		return propagationRequired;
+	}
+
+	private Set<Class<?>> findAllClassesUsingGuava(String packageName) throws IOException {
+		logger.trace("Orm mappers packageName: {}", packageName);
+		return ClassPath.from(ClassLoader.getSystemClassLoader()).getAllClasses().stream()
+				.peek(clazz -> logger.trace("candidate class: {}, package name: {}", clazz, clazz.getPackageName()))
+				.filter(clazz -> clazz.getPackageName().endsWith(packageName))
+				.peek(clazz -> logger.info("accepted class: {}, package name: {}", clazz, clazz.getPackageName()))
+				.map(clazz -> {
+					try {
+						if (clazz.getName().startsWith(springBootClassPrefix)) {
+							return Class.forName(clazz.getName().replace(springBootClassPrefix, ""));
+						}
+						return Class.forName(clazz.getName());
+					} catch (ClassNotFoundException e) {
+						logger.error("cannot convert this class name to class: {}", clazz.getName());
+					}
+					return null;
+				}).filter(Objects::nonNull).collect(Collectors.toSet());
+	}
+}
--- a/src/main/java/com/example/sbcamel/SecurityConfig.java
+++ b/src/main/java/com/example/sbcamel/SecurityConfig.java
@ -1,4 +1,4 @@
-package com.example.camel;
+package com.example.sbcamel;

 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
@ -35,9 +35,8 @@ public class SecurityConfig {

 	@Bean
 	public SecurityFilterChain securityFilterChain(HttpSecurity http) throws Exception {
-		http.authorizeHttpRequests(
-				(authorize) -> authorize.requestMatchers(HttpMethod.GET, "/**").hasAuthority(ROLE_BACKEND)
-				.requestMatchers(HttpMethod.POST, "/**").hasAuthority(ROLE_SERVER))
+		http.authorizeHttpRequests((authorize) -> authorize.requestMatchers(HttpMethod.GET, "/**")
+				.hasAuthority(ROLE_BACKEND).requestMatchers(HttpMethod.POST, "/**").hasAuthority(ROLE_SERVER))
 				.httpBasic(Customizer.withDefaults()).csrf(csrf -> csrf.disable());
 		return http.build();
 	}
--- a/src/main/java/com/example/sbcamel/User.java
+++ b/src/main/java/com/example/sbcamel/User.java
@ -0,0 +1,52 @@
+package com.example.sbcamel;
+
+import java.io.Serializable;
+import java.util.StringJoiner;
+
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Size;
+
+/**
+ * User entity
+ *
+ */
+@SuppressWarnings("serial")
+public class User implements Serializable {
+
+	@NotNull(message = "custom message")
+	private Integer id;
+
+	@NotNull
+	@Size(min = 3, max = 20)
+	private String name;
+
+	public User() {
+	}
+
+	public User(Integer id, String name) {
+		this.id = id;
+		this.name = name;
+	}
+
+	public Integer getId() {
+		return id;
+	}
+
+	public void setId(Integer id) {
+		this.id = id;
+	}
+
+	public String getName() {
+		return name;
+	}
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	@Override
+	public String toString() {
+		return new StringJoiner(", ", User.class.getSimpleName() + "[", "]").add("id=" + id).add("name='" + name + "'")
+				.toString();
+	}
+}
--- a/src/main/java/com/example/sbcamel/UserService.java
+++ b/src/main/java/com/example/sbcamel/UserService.java
@ -0,0 +1,50 @@
+package com.example.sbcamel;
+
+import java.util.Collection;
+
+import jakarta.validation.Valid;
+import jakarta.ws.rs.Consumes;
+import jakarta.ws.rs.GET;
+import jakarta.ws.rs.POST;
+import jakarta.ws.rs.Path;
+import jakarta.ws.rs.PathParam;
+import jakarta.ws.rs.Produces;
+import jakarta.ws.rs.core.MediaType;
+
+/**
+ * Service interface for managing users.
+ */
+public interface UserService {
+
+	/**
+	 * Find a user by the given ID
+	 *
+	 * @param id the ID of the user
+	 * @return the user, or <code>null</code> if user not found.
+	 */
+	@GET
+	@Path("/user/{id}")
+	@Produces(MediaType.APPLICATION_JSON)
+	User findUser(@PathParam("id") Integer id);
+
+	/**
+	 * Find all users
+	 *
+	 * @return a collection of all users
+	 */
+	@GET
+	@Path("/user")
+	@Produces(MediaType.APPLICATION_JSON)
+	Collection<User> findUsers();
+
+	/**
+	 * Update the given user
+	 *
+	 * @param user the user
+	 */
+	@POST
+	@Path("/user")
+	@Consumes(MediaType.APPLICATION_JSON)
+	User updateUser(@Valid User user);
+
+}
--- a/src/main/java/com/example/sbcamel/mapper/UserMapper.java
+++ b/src/main/java/com/example/sbcamel/mapper/UserMapper.java
@ -0,0 +1,24 @@
+package com.example.sbcamel.mapper;
+
+import java.util.Collection;
+
+import org.apache.ibatis.annotations.Insert;
+import org.apache.ibatis.annotations.Result;
+import org.apache.ibatis.annotations.Results;
+import org.apache.ibatis.annotations.Select;
+
+import com.example.sbcamel.User;
+
+public interface UserMapper {
+
+	@Insert({ "<script>", "MERGE INTO public.\"user\" (id, name) KEY (id) VALUES (#{id}, #{name}) ", "</script>" })
+	User updateUser(User user);
+
+	@Results({ @Result(property = "id", column = "id"), @Result(property = "name", column = "name") })
+	@Select({ "<script>", "select id, name from public.\"user\" where id=#{list[0]}", "</script>" })
+	User findUser(Integer id);
+
+	@Results({ @Result(property = "id", column = "id"), @Result(property = "name", column = "name") })
+	@Select({ "<script>", "select id, name from public.\"user\" order by id", "</script>" })
+	Collection<User> findUsers();
+}
Author	SHA1	Message	Date
Yan	7c89a6361e	2.1.2 Logback.xml update, camel version minor update	4 weeks ago
Yan	fadca4d287	Remove unused files	4 weeks ago
Yan	ee7b4028de	2.1.1 Added h2 storage using camel-mybatis	4 weeks ago
Yan	21b1e672ff	v2.1.0 Add camel-zookeeper-master library to test out exclusive lock	1 month ago