#3095 AMQP 1.0 Output - Support for message body type

[timo102]

See github issue for an explanation: #3095

The word "opaque" is mentioned in the documentation (https://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-data); that is why I chose this word for the configuration option.

How to test

You need a broker with AMQP 1 support. Example: Apache ActiveMQ with docker-compose:

  activemq:
    container_name: activemq
    image: apache/activemq-classic:5.18.3
    restart: always
    ports:
      - 8161:8161
      - 5673:5672

Configuration to insert string messages:

input:
  generate:
    interval: '@every 2s'
    mapping: root = {"id":uuid_v4(),"a":"а, е, ё, и, о, у, ы, э, ю, я","c":"幸福","b":"äöüÄÖÜßabc"}

output:
  amqp_1:
    urls: [ amqp://localhost:5673/ ]
    target_address: DEMOQUEUE
    max_in_flight: 64
    content_type: string
    sasl:
      mechanism: anonymous
      user: ""
      password: ""
    metadata:
      exclude_prefixes: [ "demo" ]

Reading the messages again:

input:
  amqp_1:
    urls: [ amqp://localhost:5673/ ]
    source_address: "DEMOQUEUE"
    sasl:
      mechanism: anonymous
      user: ""
      password: ""

output:
  stdout:
    codec: lines

[CLAassistant]

All committers have signed the CLA.