23 lines
294 B
Go
23 lines
294 B
Go
package broker
|
|
|
|
import (
|
|
"log/slog"
|
|
|
|
"github.com/nats-io/nats.go"
|
|
)
|
|
|
|
type NATS struct {
|
|
*nats.Conn
|
|
}
|
|
|
|
func NewNATS(url string) *NATS {
|
|
conn, err := nats.Connect(url)
|
|
if err != nil {
|
|
slog.Error("cannot stablise a connection to server", "error", err)
|
|
}
|
|
|
|
return &NATS{
|
|
Conn: conn,
|
|
}
|
|
}
|