Compare commits

..

2 Commits

Author SHA1 Message Date
91c27b30bf fix in consul register method 2024-07-16 19:13:40 +02:00
3ed094ff55 remove deprecated amqp mod, added official amqp mod 2024-07-16 18:54:28 +02:00
2 changed files with 2 additions and 2 deletions

View File

@@ -74,7 +74,7 @@ func (s *Service) Register() error {
ID: s.GetID(), ID: s.GetID(),
// Kind: consul.ServiceKindConnectProxy, // Kind: consul.ServiceKindConnectProxy,
Name: s.Name, Name: s.Name,
Address: s.Address, Address: s.domain,
Port: s.port, Port: s.port,
Tags: s.getTags(), Tags: s.getTags(),
// Connect: &consul.AgentServiceConnect{Native: true}, // Connect: &consul.AgentServiceConnect{Native: true},

View File

@@ -3,7 +3,7 @@ package rabbitmq
import ( import (
"log" "log"
"github.com/streadway/amqp" amqp "github.com/rabbitmq/amqp091-go"
) )
func Open(url string) (*amqp.Connection, *amqp.Channel, error) { func Open(url string) (*amqp.Connection, *amqp.Channel, error) {