Merge pull request #319 from sysbot/bao/dontcreateifexist

don't recreate stream if it already exist

eventbus/jetstream/eventbus.go

@@ -74,13 +74,18 @@ func NewEventBus(url, appID string, options ...Option) (*EventBus, error) {
 		return nil, fmt.Errorf("could not create Jetstream context: %w", err)
 	}
 
+	if b.stream, err = b.js.StreamInfo(b.streamName); err == nil {
+		return b, nil
+	}
+
 	// Create the stream, which stores messages received on the subject.
 	subjects := b.streamName + ".*.*"
 	cfg := &nats.StreamConfig{
 		Name:     b.streamName,
 		Subjects: []string{subjects},
 		Storage:  nats.FileStorage,
 	}
+
 	if b.stream, err = b.js.AddStream(cfg); err != nil {
 		return nil, fmt.Errorf("could not create Jetstream stream: %w", err)
 	}