Skip to content

Latest commit

 

History

History
35 lines (24 loc) · 1.06 KB

README.md

File metadata and controls

35 lines (24 loc) · 1.06 KB
Raw

amqpsource

AMQP cloudevent source for knative eventing

Work in Progress

Currently the source can only handle AMQP messages in a very particular format due to limitations in the github.com/knative/pkg/cloudevents package:

The message must have content_type property "application/json" and a single Data section that, when converted to a string, is valid input to json.Marshal().

In future, the AmqpSource will use the lightning library to handle arbitrary AMQP messages, including messages that already encode a CloudEvents event.

Install

  1. Copy the subtree into knative/eventing-sources.

  2. Build the source's receive adapter image:

    docker build . --tag amqp-adapter:xyz

  3. Edit the value for AMQP_RA_IMAGE in config/default-amqp.yaml to point to this image.

  4. Install the eventing-sources including the AmqpSource:

    ko apply -f config/default-amqp.yaml`