@@ -249,7 +249,6 @@ func CheckNetRegAndHostUpdate(networks []string, h *models.Host, relayNodeId uui
}
if servercfg.IsMessageQueueBackend() {
- fmt.Println("1. $$$$$$$$$$$$$$$$$@@@@@@ ------------------->HEREEEEEEEE ")
mq.HostUpdate(&models.HostUpdate{
Action: models.RequestAck,
Host: *h,
@@ -98,7 +98,6 @@ func UpdateHost(client mqtt.Client, msg mqtt.Message) {
case models.Acknowledgement:
hu := hostactions.GetAction(currentHost.ID.String())
if hu != nil {
- fmt.Println("2. $$$$$$$$$$$$$$$$$@@@@@@ ------------------->HEREEEEEEEE ")
if err = HostUpdate(hu); err != nil {
slog.Error("failed to send new node to host", "name", hostUpdate.Host.Name, "id", currentHost.ID, "error", err)
return
@@ -141,7 +141,6 @@ func HostUpdate(hostUpdate *models.HostUpdate) error {
return nil
logger.Log(3, "publishing host update to "+hostUpdate.Host.ID.String())
- fmt.Printf("------>############ %s\n", hostUpdate.Action)
data, err := json.Marshal(hostUpdate)
if err != nil {
logger.Log(2, "error marshalling node update ", err.Error())