[🐛 BUG]: Jobs AMQP headers with list type not mapped to RR job

[iborysenko]

No duplicates 🥲.

• I have searched for a similar issue in our bug tracker and didn't find any solutions.

What happened?

A bug happened!
Jobs AMQP headers with list type not mapped to RR job

Version (rr --version)

2023.3

How to reproduce the issue?

Publish message with list type headers

Relevant log output

No response

[rustatian]

Hey @iborysenko 👋
Please attach a worker, configuration (.rr.yaml) and all the needed data to reproduce this problem.

EDIT: Also, attach your composer.json or specify versions. Also, if you push headers via separate script, attach it as well.

[iborysenko]

Hey @rustatian

jobs:
    pipelines:
        processing_pipeline:
            driver: amqp
            config:
              queue: my-queue
              exchange: my-exchange
              routing_key: my-queue-routing-key
              exchange_type: direct
              exchange_durable: true
              durable: true
              consume_all: true
              redial_timeout: 600

1. Go to the RabbitMQ Management UI and publish a message to the my-queue with headers (like on screenshot above)
2. Start consuming messages via RR.
3. RR forward only headers with type string but not list

---

We are using Krakend-gateway to publish webhooks to the queue, and then RR consumes them
Krakend put allowed HTTP headers to the AMQP Message Headers as List

    headerValues := make([]interface{}, len(vs))
    for k, v := range vs {
    headerValues[k] = v
    }
    headers[k] = headerValues

Anyway we will fork this lib and fix it for us, but I noticed that RR does not support these header type

[rustatian]

@iborysenko There is no list data structure in Go.

[rustatian]

I'm not sure, why do you think, that we support only string headers: https://github.com/roadrunner-server/amqp/blob/master/amqpjobs/conv.go

[iborysenko]

Try

Result will be

{"id":"99c87c46-8935-49cd-94cd-e48a9697cc36","job":"deduced_by_rr","driver":"amqp","queue":"my-queue","headers":{"Traceparent":["00-bb7aeaec5ce34668d9dd163d1ee8dccb-aa92cee3135e0710-01"],"Uber-Trace-Id":["bb7aeaec5ce34668d9dd163d1ee8dccb:aa92cee3135e0710:0:1"],"stringHeader":["stringValue"]},"pipeline":"processing_pipeline"}

[rustatian]

Ok, in your case, this would be a slice of any types which are actually strings. I'll add a switch case for that and release a bugfix.