Commit Graph

19 Commits

Author SHA1 Message Date
Oleg Zhurakousky
bc4b5b3f80 Add stream (kafka, Rabbit) and Rsocket examples for Cloud Event 2020-12-18 16:44:29 +01:00
Oleg Zhurakousky
eb95e1dd78 Modify logic for header copy from input to output
This is primarily related to Cloud Events. Since we delegate to a separate class for post processing, if outpt message is Cloud Event we will not be doing anything to with regard to header copy in SimpleFunctionRegistry and unstead delegate it to CloudEventFunctionInvocationHelper
2020-12-18 16:44:19 +01:00
Oleg Zhurakousky
98c9d56442 Change canonical format of Cloud Event Message attributes to have 'ce-' prefix 2020-12-02 11:24:03 +01:00
Oleg Zhurakousky
28184039de Restructure Cloud Events support to optionally support Cloud Events SDK 2020-12-01 22:12:34 +01:00
Oleg Zhurakousky
07a699b99d GH-422, GH-606 Fis structure mode attribute generation 2020-11-16 17:44:07 +01:00
Oleg Zhurakousky
8a3cbed877 GH-422, GH-606 Improve generation of default attributes for Consumer 2020-11-16 16:49:59 +01:00
Oleg Zhurakousky
8993a9751f GH-422, GH-606 Add support for generating attributes using provider in Consumer 2020-11-16 16:27:54 +01:00
Oleg Zhurakousky
1a6e9d4a80 GH-422, GH-606 Fix attributes generatioin 2020-11-16 14:20:02 +01:00
Oleg Zhurakousky
8ea309c45b Clean up and simplifications around CloudEvent processing
This commit effectively a merge of work with #607 and simplifies the following
- CloudEventAttributesProvider now provides CloudEventAttributes initialized with defaults to be set by the user
- In HTTP RequestProcessor the logic of sanitizing headers was improved to ensure that correct prefix is applied

Resolves #607
2020-11-16 13:40:53 +01:00
Oleg Zhurakousky
40d06b8c95 GH-422 GH-606 Add support for normalizing structure-mode CE message
Normalizing in this context means converting it to binary-mode so the rest of the processing logic is the same.
Added support for canonical attribute names. Now, internally any attribute can be set as 'ce_' regardless where it came from are where it goes to as the frameork will be able to recognize both
Removed CloudEventMessageConverter
Renamed CloudEventAttributes to CloudEventAttributesHelperas it is better suited to what it actually does
2020-11-16 12:06:33 +01:00
Oleg Zhurakousky
b9f417a4da Make CloudEventAttributesProvider a FunctionalInterface
Related to #422 and #606
2020-11-16 08:41:42 +01:00
Oleg Zhurakousky
1d67b8070f Add PojoToPojo and MapToMap tests
Related to GH-422 and GH-606
2020-11-13 18:44:01 +01:00
Oleg Zhurakousky
14b39c2077 Fix HTTP header propagation logic
Related to GH-422 and GH-606
2020-11-13 17:47:41 +01:00
Oleg Zhurakousky
632e73caf9 Fix CloudEvent prefix and fix the name of CloudEventAttributesProvider.java 2020-11-13 16:07:33 +01:00
Oleg Zhurakousky
1a16af46de GH-606 add initila support for generating default cloud event attributes 2020-11-13 11:39:48 +01:00
Oleg Zhurakousky
f0b2ce7691 GH-422 GH-606 Add support for simplifying message headers to attribute mapping
Added CloudEventAttributesProvider and default implementation
Added CloudEventMessageUtils
2020-11-13 10:24:27 +01:00
Oleg Zhurakousky
27d0d8afd9 GH-422 Add RabbitMQ instructions for Cloud Events interaction 2020-11-11 11:53:39 +01:00
Oleg Zhurakousky
97347bf30d GH-422 Improvements in cloud event samples
Added initial README
Polished tests
2020-11-11 09:18:51 +01:00
Oleg Zhurakousky
b8c02587e9 GH-422 Add initial set of Cloud Event samples
This commit adds initial set of samples and tests demonstrating various ways of how cloud event can be consumed (i.e., structured, bindary, pojo etc)
2020-11-10 16:29:30 +01:00