This commit is contained in:
nquidox 2026-04-08 12:17:25 +03:00
parent 7fbc196c84
commit bcc6ea2d29
2 changed files with 3 additions and 1 deletions

View file

@ -47,6 +47,8 @@ func New(deps Deps) TaskTransport {
}
func (h *Handler) initConsumer(deps *Deps) error {
log.WithField("enabled", deps.LoggingEnabled).Debugf("%v rabbit mq logger", pkgLogHeader)
client, err := rabbit.NewClient(rabbit.Address{
Username: deps.Username,
Password: deps.Password,