Changes the KV bucket sourcing code to use the SubjectTransforms array

nats-io · Sep 20, 2023 · 06bbf5f · 06bbf5f
1 parent 7d66f4a
commit 06bbf5f
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/kv.go b/kv.go
@@ -442,8 +442,7 @@ func (js *js) CreateKeyValue(cfg *KeyValueConfig) (KeyValue, error) {
 			}
 
 			if ss.External == nil || sourceBucketName != cfg.Bucket {
-				ss.FilterSubject = fmt.Sprintf(kvSubjectsTmpl, sourceBucketName)
-				ss.SubjectTransformDest = fmt.Sprintf(kvSubjectsTmpl, cfg.Bucket)
+				ss.SubjectTransforms = []SubjectTransformConfig{{Source: fmt.Sprintf(kvSubjectsTmpl, sourceBucketName), Destination: fmt.Sprintf(kvSubjectsTmpl, cfg.Bucket)}}
 			}
 			scfg.Sources = append(scfg.Sources, ss)
 		}