diff --git a/natsio.go b/natsio.go index 3692fbf..f3f7845 100644 --- a/natsio.go +++ b/natsio.go @@ -55,6 +55,11 @@ func Connect(cfg Config) error { return nil } +// GetClient ... +func GetClient() *nats.Conn { + return natsClient +} + // GetJetStream ... func GetJetStream() nats.JetStreamContext { return natsJS