adds mirroring test for kv

micronaut-projects · Feb 8, 2024 · 2b8d972 · 2b8d972
1 parent 02640e8
commit 2b8d972
Showing 1 changed file with 27 additions and 1 deletion.
diff --git a/nats/src/test/groovy/io/micronaut/nats/jetstream/KeyValueSpec.groovy b/nats/src/test/groovy/io/micronaut/nats/jetstream/KeyValueSpec.groovy
@@ -99,12 +99,38 @@ class KeyValueSpec extends AbstractJetstreamTest {
         applicationContext.close()
     }
 
+    void "mirroring key value"() {
+        given:
+        ApplicationContext context = startContext([
+                "nats.default.jetstream.keyvalue.m-examplebucket.storage-type": "Memory",
+                "nats.default.jetstream.keyvalue.m-examplebucket.mirror.name": "examplebucket",
+        ])
+        KeyValueManagement kvm = context.getBean(KeyValueManagement, Qualifiers.byName(NatsConnection.DEFAULT_CONNECTION))
+        KeyValueHolder kvHolder = context.getBean(KeyValueHolder)
+
+        when:
+        kvHolder.keyValueBucket.put("hello", "world")
+
+        then:
+        kvHolder.mirror.get("hello").valueAsString == "world"
+
+        cleanup:
+        kvm.delete("examplebucket")
+        kvm.delete("m-examplebucket")
+        context.close()
+    }
+
+
 
     @Requires(property = 'spec.name', value = 'KeyValueSpec')
     @Singleton
     static class KeyValueHolder {
         @Inject
         @KeyValueStore('examplebucket')
-        KeyValue keyValueBucket;
+        KeyValue keyValueBucket
+
+        @Inject
+        @KeyValueStore('m-examplebucket')
+        KeyValue mirror;
     }
 }