Revert changes made to streams

setup/jetstream/nats.go

@@ -74,6 +74,7 @@ func setupNATS(cfg *config.JetStream, nc *natsclient.Conn) (sarama.Consumer, sar
 			logrus.WithError(err).Fatal("Unable to get stream info")
 		}
 		if info == nil {
+			stream.Subjects = []string{stream.Name}
 			// If we're trying to keep everything in memory (e.g. unit tests)
 			// then overwrite the storage policy.
 			if cfg.InMemory {

setup/jetstream/streams.go

@@ -18,38 +18,32 @@ var (
 var streams = []*nats.StreamConfig{
 	{
 		Name:      OutputRoomEvent,
-		Subjects:  []string{OutputRoomEvent},
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
 	},
 	{
 		Name:      OutputSendToDeviceEvent,
-		Subjects:  []string{OutputSendToDeviceEvent},
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
 	},
 	{
 		Name:      OutputKeyChangeEvent,
-		Subjects:  []string{OutputKeyChangeEvent},
 		Retention: nats.LimitsPolicy,
 		Storage:   nats.FileStorage,
 	},
 	{
 		Name:      OutputTypingEvent,
-		Subjects:  []string{OutputTypingEvent},
 		Retention: nats.InterestPolicy,
 		Storage:   nats.MemoryStorage,
 		MaxAge:    time.Second * 60,
 	},
 	{
 		Name:      OutputClientData,
-		Subjects:  []string{OutputClientData},
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
 	},
 	{
 		Name:      OutputReceiptEvent,
-		Subjects:  []string{OutputReceiptEvent},
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
 	},