CAMEL-26957: camel-nats - a DST fake world for the JetStream pull consumer

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/nats.json

@@ -131,5 +131,8 @@
     "credentialsFilePath": { "index": 41, "kind": "parameter", "displayName": "Credentials File Path", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.nats.NatsConfiguration", "configurationField": "configuration", "description": "If we use useCredentialsFile to true we'll need to set the credentialsFilePath option. It can be loaded by default from classpath, but you can prefix with classpath:, file:, or http: to load the resource from different systems." },
     "secure": { "index": 42, "kind": "parameter", "displayName": "Secure", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.nats.NatsConfiguration", "configurationField": "configuration", "description": "Set secure option indicating TLS is required" },
     "sslContextParameters": { "index": 43, "kind": "parameter", "displayName": "Ssl Context Parameters", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.nats.NatsConfiguration", "configurationField": "configuration", "description": "To configure security using SSLContextParameters" }
+  },
+  "dstWorlds": {
+    "NatsWorld": { "javaType": "org.apache.camel.component.nats.dst.NatsWorld", "fake": "FakeJetStream: a server with one JetStream stream and its pull consumers (AckWait, MaxDeliver, Nak), behind a jnats Connection given with the connection option", "covers": [ "the JetStream pull consumer with explicit acks and naks, ephemeral or durable", "AckWait and MaxDeliver", "route stop and start, also while the consumer waits in a fetch", "a server restart that deletes the ephemeral consumer, and the subscription made again" ], "faults": [ "a fetch ends empty while the connection is down", "the flush of the stop times out", "an ack is lost", "the server restarts (409 Server Shutdown) or the consumer is deleted (409 Consumer Deleted)", "processing fails", "processing is slower than AckWait" ], "invariants": [ "the consumer uses the connection as documented", "a message is acknowledged only after its exchange completed", "a message is nak'd only after its exchange failed", "a stopped consumer leaves no subscription active", "every message is acknowledged once the faults cleared, or given up after MaxDeliver (or skipped by a consumer made again after its ack was lost)" ], "issues": [ "CAMEL-26884" ], "tests": [ "NatsConsumerDstTest" ] }
   }
 }

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/test-dst.adoc

@@ -103,6 +103,15 @@ a|* explicit acknowledgement with onFailure RELEASE or REJECT
 * suspend and resume of the CamelContext
 |CAMEL-25872, CAMEL-25910
 
+|camel-nats
+|`NatsWorld` (`NatsConsumerDstTest`)
+|FakeJetStream: a server with one JetStream stream and its pull consumers (AckWait, MaxDeliver, Nak), behind a jnats Connection given with the connection option
+a|* the JetStream pull consumer with explicit acks and naks, ephemeral or durable
+* AckWait and MaxDeliver
+* route stop and start, also while the consumer waits in a fetch
+* a server restart that deletes the ephemeral consumer, and the subscription made again
+|CAMEL-26884
+
 |camel-pulsar
 |`PulsarWorld` (`PulsarConsumerDstTest`)
 |FakePulsar: a broker and client for one topic and one durable subscription

components/camel-nats/pom.xml

@@ -34,6 +34,8 @@
     <properties>
         <!-- Nats container is not available on these platforms -->
         <skipITs.s390x>true</skipITs.s390x>
+        <!-- the DST tests load the byte code agent of camel-test-dst when the JVM starts (see test-dst.adoc) -->
+        <camel.surefire.fork.additional-vmargs>"-javaagent:${net.bytebuddy:byte-buddy-agent:jar}"</camel.surefire.fork.additional-vmargs>
     </properties>
 
     <dependencies>
@@ -67,5 +69,35 @@
             <version>${slf4j-version}</version>
             <scope>test</scope>
         </dependency>
+        <!-- deterministic simulation test of the JetStream pull consumer (dst package) -->
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-test-dst</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
+            <version>${mockito-version}</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <!-- sets the property net.bytebuddy:byte-buddy-agent:jar to the path of the agent of the DST tests -->
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-dependency-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <id>dst-agent-path</id>
+                        <goals>
+                            <goal>properties</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
 </project>

components/camel-nats/src/generated/resources/META-INF/org/apache/camel/component/nats/nats.json

@@ -131,5 +131,8 @@
     "credentialsFilePath": { "index": 41, "kind": "parameter", "displayName": "Credentials File Path", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.nats.NatsConfiguration", "configurationField": "configuration", "description": "If we use useCredentialsFile to true we'll need to set the credentialsFilePath option. It can be loaded by default from classpath, but you can prefix with classpath:, file:, or http: to load the resource from different systems." },
     "secure": { "index": 42, "kind": "parameter", "displayName": "Secure", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.nats.NatsConfiguration", "configurationField": "configuration", "description": "Set secure option indicating TLS is required" },
     "sslContextParameters": { "index": 43, "kind": "parameter", "displayName": "Ssl Context Parameters", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.nats.NatsConfiguration", "configurationField": "configuration", "description": "To configure security using SSLContextParameters" }
+  },
+  "dstWorlds": {
+    "NatsWorld": { "javaType": "org.apache.camel.component.nats.dst.NatsWorld", "fake": "FakeJetStream: a server with one JetStream stream and its pull consumers (AckWait, MaxDeliver, Nak), behind a jnats Connection given with the connection option", "covers": [ "the JetStream pull consumer with explicit acks and naks, ephemeral or durable", "AckWait and MaxDeliver", "route stop and start, also while the consumer waits in a fetch", "a server restart that deletes the ephemeral consumer, and the subscription made again" ], "faults": [ "a fetch ends empty while the connection is down", "the flush of the stop times out", "an ack is lost", "the server restarts (409 Server Shutdown) or the consumer is deleted (409 Consumer Deleted)", "processing fails", "processing is slower than AckWait" ], "invariants": [ "the consumer uses the connection as documented", "a message is acknowledged only after its exchange completed", "a message is nak'd only after its exchange failed", "a stopped consumer leaves no subscription active", "every message is acknowledged once the faults cleared, or given up after MaxDeliver (or skipped by a consumer made again after its ack was lost)" ], "issues": [ "CAMEL-26884" ], "tests": [ "NatsConsumerDstTest" ] }
   }
 }