diff --git a/amqp/amqp_endpoints.go b/amqp/amqp_endpoints.go index 2683c86..64cdf13 100644 --- a/amqp/amqp_endpoints.go +++ b/amqp/amqp_endpoints.go @@ -27,7 +27,6 @@ import ( "git.rwth-aachen.de/acs/public/villas/web-backend-go/routes/infrastructure-component" "github.com/gin-gonic/gin" "net/http" - "time" ) func RegisterAMQPEndpoint(r *gin.RouterGroup) { @@ -62,14 +61,14 @@ func sendActionToIC(c *gin.Context) { return } - now := time.Now() + //now := time.Now() for _, action := range actions { - if action.When == 0 { + /*if action.When == 0 { action.When = float32(now.Unix()) - } - - err = SendActionAMQP(action, s.UUID) + }*/ + *action.UUID = s.UUID + err = SendActionAMQP(action) if err != nil { helper.InternalServerError(c, "Unable to send actions to IC: "+err.Error()) return diff --git a/amqp/amqpclient.go b/amqp/amqpclient.go index 4d961a6..9f2187d 100644 --- a/amqp/amqpclient.go +++ b/amqp/amqpclient.go @@ -46,8 +46,9 @@ type Action struct { Act string `json:"action"` When float32 `json:"when"` Parameters struct{} `json:"parameters"` - Model struct{} `json:"model"` - Results struct{} `json:"results"` + UUID *string `json:"uuid"` + //Model struct{} `json:"model"` + //Results struct{} `json:"results"` } type ICUpdate struct { @@ -133,7 +134,7 @@ func ConnectAMQP(uri string) error { return nil } -func SendActionAMQP(action Action, uuid string) error { +func SendActionAMQP(action Action) error { payload, err := json.Marshal(action) if err != nil { @@ -149,11 +150,12 @@ func SendActionAMQP(action Action, uuid string) error { Body: payload, } - if uuid != "" { - msg.Headers["uuid"] = uuid - msg.Headers["action"] = "ping" + err = CheckConnection() + if err != nil { + return err } + log.Println("AMQP: Sending message", string(msg.Body)) err = client.channel.Publish(VILLAS_EXCHANGE, "", false, @@ -168,8 +170,9 @@ func PingAMQP() error { var a Action a.Act = "ping" + *a.UUID = "" - err := SendActionAMQP(a, "") + err := SendActionAMQP(a) return err }