Commit 9e235235 authored by Sonja Happ's avatar Sonja Happ
Browse files

AMQP: try to make access to headers work

parent e0b8ccdd
......@@ -263,7 +263,8 @@ func processMessage(message amqp.Delivery) error {
}
payload.Status.UUID = new(string)
*payload.Status.UUID = fmt.Sprintf("%v", message.Headers["uuid"])
headers := amqp.Table(message.Headers)
*payload.Status.UUID = fmt.Sprintf("%v", headers["uuid"])
if payload.Status != nil {
//log.Println("Processing AMQP message: ", string(message.Body))
......
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