Commit 034cb83e authored by Sonja Happ's avatar Sonja Happ
Browse files

AMQP: read UUID in status update from header of AMQP message instead of payload

parent 561f7cf6
......@@ -262,6 +262,8 @@ func processMessage(message amqp.Delivery) error {
return fmt.Errorf("AMQP: Could not unmarshal message to JSON: %v err: %v", string(message.Body), err)
}
payload.Status.UUID = fmt.Sprintf("%v", message.Headers["uuid"])
if payload.Status != nil {
//log.Println("Processing AMQP message: ", string(message.Body))
// if a message contains a "state" field, it is an update for an IC
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment