diff --git a/controllers/ext_client.go b/controllers/ext_client.go index 35d6358a..1e2f29f2 100644 --- a/controllers/ext_client.go +++ b/controllers/ext_client.go @@ -398,7 +398,7 @@ func createExtClient(w http.ResponseWriter, r *http.Request) { if err := mq.PublishPeerUpdate(); err != nil { logger.Log(1, "error setting ext peers on "+nodeid+": "+err.Error()) } - if err := mq.PublishExtCLientDNS(&extclient); err != nil { + if err := mq.PublishExtClientDNS(&extclient); err != nil { logger.Log(1, "error publishing extclient dns", err.Error()) } }() diff --git a/mq/publishers.go b/mq/publishers.go index ac195aa3..a470b99e 100644 --- a/mq/publishers.go +++ b/mq/publishers.go @@ -79,8 +79,10 @@ func PublishDeletedClientPeerUpdate(delClient *models.ExtClient) error { } for _, host := range hosts { host := host - if err = PublishSingleHostPeerUpdate(&host, nodes, nil, []models.ExtClient{*delClient}); err != nil { - logger.Log(1, "failed to publish peer update to host", host.ID.String(), ": ", err.Error()) + if host.OS != models.OS_Types.IoT { + if err = PublishSingleHostPeerUpdate(&host, nodes, nil, []models.ExtClient{*delClient}); err != nil { + logger.Log(1, "failed to publish peer update to host", host.ID.String(), ": ", err.Error()) + } } } return err @@ -258,7 +260,7 @@ func PublishReplaceDNS(oldNode, newNode *models.Node, host *models.Host) error { } // PublishExtClientDNS publish dns update for new extclient -func PublishExtCLientDNS(client *models.ExtClient) error { +func PublishExtClientDNS(client *models.ExtClient) error { errMsgs := models.DNSError{} dns := models.DNSUpdate{ Action: models.DNSInsert,