From 2e90610cce926bf09e6380a68cdd42cc3cd4c7f4 Mon Sep 17 00:00:00 2001 From: S7evinK Date: Thu, 31 Mar 2022 08:12:27 +0200 Subject: [PATCH] Add new presence stream --- setup/jetstream/streams.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/setup/jetstream/streams.go b/setup/jetstream/streams.go index 5f0d37fdc..eacc04ebb 100644 --- a/setup/jetstream/streams.go +++ b/setup/jetstream/streams.go @@ -25,6 +25,8 @@ var ( OutputReceiptEvent = "OutputReceiptEvent" OutputStreamEvent = "OutputStreamEvent" OutputReadUpdate = "OutputReadUpdate" + RequestPresence = "GetPresence" + OutputPresenceEvent = "OutputPresenceEvent" ) var safeCharacters = regexp.MustCompile("[^A-Za-z0-9$]+") @@ -89,4 +91,9 @@ var streams = []*nats.StreamConfig{ Retention: nats.InterestPolicy, Storage: nats.FileStorage, }, + { + Name: OutputPresenceEvent, + Retention: nats.InterestPolicy, + Storage: nats.FileStorage, + }, }