Is there support for AMQP RabbitMQ Header Exchange?

[linssenit]

Hi,

I'm trying to connect an EventSource to a RabbitMQ Header Exchange using Argo Events. According to the documentation, it seems like RabbitMQ exchanges are supported:
📄 https://argoproj.github.io/argo-events/APIs/#argoproj.io/v1alpha1.AMQPEventSource

I've experimented a bit and applied the YAML below, but ran into two issues:

• The routingKey field appears to be required, but Header Exchanges don’t use routing keys.

• The arguments section (e.g., x-match) doesn’t seem to be applied or passed through correctly.

Has anyone else tried this setup and found a workaround or solution?

apiVersion: argoproj.io/v1alpha1
kind: EventSource
metadata:
  name: rabbitmq-exclusions
  namespace: argo-events
spec:
  amqp:
    exclusions:
      # amqp server url
      url: amqp://u:p@rabbitmq.rabbitmq-system.svc.cluster.local:5672/
      # jsonBody specifies that all event body payload coming from this
      # source will be JSON
      jsonBody: true
      # name of the exchange.
      exchangeName: existing-exchange
      # exchange type. more info at https://www.rabbitmq.com/tutorials/amqp-concepts.html#exchanges
      exchangeType: headers
      # routing key
      routingKey: keyName
      # optional backoff time for connection retries.
      # if not provided, default connection backoff time will be used.
      connectionBackoff:
        # duration in nanoseconds, or strings like "1s", "1m". following value is 10 seconds
        duration: 10s
        # how many backoffs
        steps: 5
        # factor to increase on each step.
        # setting factor > 1 makes backoff exponential.
        factor: 2
        jitter: 0.2
      # optional exchange settings
      # if not provided, default values will be used
      exchangeDeclare:
        durable: true
        autoDelete: false
        internal: false
        noWait: false
      # optional queue settings
      # if not provided, default values will be used
      queueDeclare:
        name: "queue-2"
        durable: false
        autoDelete: false
        exclusive: true
        noWait: false
        arguments: |-
          x-match: all
      # optional queue binding settings
      # if not provided, default values will be used
      queueBind:
        noWait: false
      # optional consume settings
      # if not provided, default values will be used
      consume:
        consumerTag: "my-consumer-tag"
        autoAck: true
        exclusive: false
        noLocal: false
        noWait: false