From b511f3fd7a55a5eaad044344ff2dd80e3dfd38ba Mon Sep 17 00:00:00 2001 From: Matthias Hanel Date: Tue, 10 Aug 2021 13:51:20 -0400 Subject: [PATCH] fixed unit test to require fc export as well Signed-off-by: Matthias Hanel --- server/jetstream_cluster_test.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/server/jetstream_cluster_test.go b/server/jetstream_cluster_test.go index 7e6aee2c..2ae97422 100644 --- a/server/jetstream_cluster_test.go +++ b/server/jetstream_cluster_test.go @@ -4893,7 +4893,8 @@ func TestJetStreamCrossAccountMirrorsAndSources(t *testing.T) { t.Fatalf("Unexpected error: %v", err) } - toSend := 100 + // use large number to tease out FC issues + toSend := 3000 for i := 0; i < toSend; i++ { if _, err := js.Publish("TEST", []byte("OK")); err != nil { t.Fatalf("Unexpected publish error: %v", err) @@ -8193,6 +8194,7 @@ var jsClusterMirrorSourceImportsTempl = ` exports [ { service: "$JS.API.CONSUMER.>" } # To create internal consumers to mirror/source. { stream: "RI.DELIVER.SYNC.>" } # For the mirror/source consumers sending to IA via delivery subject. + { service: "$JS.FC.>" } ] } IA { @@ -8201,6 +8203,7 @@ var jsClusterMirrorSourceImportsTempl = ` imports [ { service: { account: JS, subject: "$JS.API.CONSUMER.>"}, to: "RI.JS.API.CONSUMER.>" } { stream: { account: JS, subject: "RI.DELIVER.SYNC.>"} } + { service: {account: JS, subject: "$JS.FC.>" }} ] } $SYS { users = [ { user: "admin", pass: "s3cr3t!" } ] }