Skip to content

Commit

Permalink
re-use existing template definition
Browse files Browse the repository at this point in the history
Co-authored-by: Piotr Piotrowski <piotr@synadia.com>
  • Loading branch information
jnmoyne and piotrpio committed Feb 1, 2023
1 parent 7be647c commit 41ed469
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion kv.go
Expand Up @@ -425,7 +425,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("$KV.%s.>", cfg.Bucket)
ss.SubjectTransformDest = fmt.Sprintf(kvSubjectsTmpl, cfg.Bucket)
}
scfg.Sources = append(scfg.Sources, ss)
}
Expand Down

0 comments on commit 41ed469

Please sign in to comment.