natsio.go

@@ -21,9 +21,6 @@ type JetStream struct {
 var (
 	natsServer    Server
 	natsJetStream JetStream
-
-	// FIXME: delete this
-	jsPublic nats.JetStreamContext
 )
 
 // Connect ...
@@ -65,9 +62,6 @@ func Connect(cfg Config) error {
 	}
 	natsJetStream.instance = js
 
-	// FIXME: delete this
-	jsPublic = js
-
 	return nil
 }
 
@@ -80,8 +74,3 @@ func GetServer() Server {
 func GetJetStream() JetStream {
 	return natsJetStream
 }
-
-// GetJSPublic ...
-func GetJSPublic() nats.JetStreamContext {
-	return jsPublic
-}