591d133f31
Add MQTT as a `Message` format. This commit adds `MQTT` to the supported transport protocols by adding a `Binding` and the `MQTTMessage<T>` type, extending the base `Message` type, adding the MQTT fields for `payload`, `PUBLISH` and `User Properties`. The `payload` field directly maps to `Message#body`, while `User Properties` roughly maps to `Message#headers`, even though the properties here are not formatted with a `ce-` prefix like other transport protocols. This is per the spec. See: https://github.com/cloudevents/spec/blob/v1.0.1/mqtt-protocol-binding.md. Signed-off-by: Lance Ball <lball@redhat.com> |
||
|---|---|---|
| .. | ||
| batch_test.ts | ||
| ce.png | ||
| cloud_event_test.ts | ||
| constants_test.ts | ||
| emitter_factory_test.ts | ||
| emitter_singleton_test.ts | ||
| kafka_tests.ts | ||
| message_test.ts | ||
| mqtt_tests.ts | ||
| parser_test.ts | ||
| sdk_test.ts | ||
| spec_1_tests.ts | ||
| utilities_test.ts | ||
