diff --git a/fly/notifier/vaa_last_sequence.go b/fly/notifier/vaa_last_sequence.go index 62ee36c15..059936bbb 100644 --- a/fly/notifier/vaa_last_sequence.go +++ b/fly/notifier/vaa_last_sequence.go @@ -43,7 +43,7 @@ func NewLastSequenceNotifier(c *redis.Client, prefix string) *LastSequenceNotifi if prefix == "" { prefix = "wormscan:vaa-max-sequence" } else { - prefix = fmt.Sprintf("%s-wormscan:vaa-max-sequence", prefix) + prefix = fmt.Sprintf("%s:wormscan:vaa-max-sequence", prefix) } return &LastSequenceNotifier{ diff --git a/fly/notifier/vaa_last_sequence_test.go b/fly/notifier/vaa_last_sequence_test.go index 072fd8c1a..1dac57415 100644 --- a/fly/notifier/vaa_last_sequence_test.go +++ b/fly/notifier/vaa_last_sequence_test.go @@ -12,7 +12,7 @@ func TestNewLastSequenceNotifier(t *testing.T) { l := NewLastSequenceNotifier(nil, "mainnet-staging") - assert.Equal(t, "mainnet-staging-wormscan:vaa-max-sequence", l.prefix) + assert.Equal(t, "mainnet-staging:wormscan:vaa-max-sequence", l.prefix) } func TestNewLastSequenceNotifierBackwardsCompat(t *testing.T) { @@ -33,5 +33,5 @@ func TestNewLastSequenceNotifierWithPrefix(t *testing.T) { l := NewLastSequenceNotifier(nil, prefix) - assert.Equal(t, "mainnet-staging-wormscan:vaa-max-sequence", l.prefix) + assert.Equal(t, "mainnet-staging:wormscan:vaa-max-sequence", l.prefix) }