cloudevents
/
sdk-java
mirror of https://github.com/cloudevents/sdk-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
809 Commits 20 Branches 32 Tags 4.1 MiB
Commit Graph

809 Commits

Author SHA1 Message Date
Fabio José b14b6b0652 Adding imports in the examples docs 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-20 12:41:51 -03:00
Fabio José 0857dfa4ca Preparation for pr, add right version compare links 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-20 12:41:15 -03:00
Fabio José b7aa38eacb Kafka consumer tests 
Binary content mode

Spec 0.3

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 23:05:04 -03:00
Fabio José efc32d5c09 Top-level unmarshallers for spec 0.3 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 23:04:25 -03:00
Fabio José b0483f3a8c Filter to remove non-ce headers 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 23:04:02 -03:00
Fabio José cac367cf8e Builder with base instance 
Fix of() method to process extensions

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 23:03:08 -03:00
Fabio José 5e86c215bc Attributes v0.3 unmarshaller 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 23:02:12 -03:00
Fabio José 272c6ad568 Testing for kafka producer 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:53:49 -03:00
Fabio José f57cc6ad65 Common marshall method 
Takes an attributes impl and produces a map

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:44:30 -03:00
Fabio José 838a730258 Top-level marshallers for kafka 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:43:27 -03:00
Fabio José 528563b563 License comment and new attributes 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:31:15 -03:00
Fabio José af39059327 Private constructor to prevent instances creationg 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:30:50 -03:00
Fabio José c11ca15fc4 Kafka header mapper for (un)marshalling 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:30:04 -03:00
Fabio José 9b41ae001d Kafka extension mapper for (un)marshalling 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:29:43 -03:00
Fabio José 8327a97b04 Kafka Attributes mapper for spec 0.2 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:19:49 -03:00
Fabio José cb3364e714 Override (de)serializers 
The value (de)serializer always must be bytearray

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:05:05 -03:00
Fabio José 61e63ed367 Document the low-level (un)marshallers 
The structured and binary content modes to create your own

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:03:06 -03:00
Fabio José 879c6e81b1 Fix english grammer 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 22:28:31 -03:00
Fabio José e626dc45ce Unreleased link 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 22:25:10 -03:00
Fabio José f6a85d0b40 Document the dependency config 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 22:19:54 -03:00
Fabio José 6a248907f9 Update snippets with new sdk api 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 22:19:24 -03:00
Fabio José 4b47abe4e4 Update version of maven deps 
Fix kafka docs link

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 22:12:55 -03:00
Fabio José cac81e32ad Link to kafka and api docs 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 22:11:20 -03:00
Fabio José 1f6a6009d9 Document the use of (un)marshalelrs 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 22:02:02 -03:00
Fabio José 29466509f4 Json decoding using JavaType 
Decode binary and string

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:42:03 -03:00
Fabio José 7aedf64ea8 Document how to use (un)marshallers 
The structured and binary hight level

How to create my own (un)marshaller

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:41:09 -03:00
Fabio José 33393ce26c Document the changes 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:39:48 -03:00
Fabio José d4c1cb2825 Tests for structured kafka consumer 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:39:24 -03:00
Fabio José 4e4ded70dc Right name for the test 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:39:02 -03:00
Fabio José 089f976540 structure unmarshaller definition 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:38:37 -03:00
Fabio José f3cd10ac93 Use of hight level unmarshaller 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:37:36 -03:00
Fabio José b2436c94ee Remove the unused steps tests 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:36:57 -03:00
Fabio José de58785f62 Umarshaller for structured content mode 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:36:18 -03:00
Fabio José 0ac54691d7 Remove unused steps 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:35:52 -03:00
Fabio José b4b7b2a37b Use of constants 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:35:21 -03:00
Fabio José 90d08f0678 Boilerplate 
KafkaConsumer and KafkaPRoducer to delegate calls, as internal attribute by composition

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-17 22:58:40 -03:00
Fabio José 3ec841c33c Test the tracing unmarshal from header 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-17 22:57:11 -03:00
Fabio José f23bb3e8a3 Test the extensions unmarshal from headers 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-17 22:56:30 -03:00
Fabio José 58449faa87 Tests with extensions list 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-17 22:55:58 -03:00
Fabio José a62510671f Top level private constructor 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-17 22:55:36 -03:00
Fabio José 0b58bc9bc7 Builder method with base event to copy attributes, extensions and data 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-17 22:55:07 -03:00
Fabio José 8fb128e992 Process extensions from headers 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-17 22:54:27 -03:00
Fabio José f0ed9b9786 Way get the extensions from headers 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-17 22:53:55 -03:00
Fabio José cdb638157d Impl the send that pass a callback arg 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-16 22:12:26 -03:00
Fabio José 533e95b755 java doc @see 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-16 22:06:50 -03:00
Fabio José e6f4b691d5 Line feed 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-16 22:06:28 -03:00
Fabio José ad2074d48d Use of (un)marshallers 
Reduce the boilerplate

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-16 22:06:09 -03:00
Fabio José 5df373310e Kafka marshallers and unmarshallers for json 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-16 22:05:30 -03:00
Fabio José efd60454ee Use of marshallers and unmarshallers for HTTP 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-16 21:43:40 -03:00
Fabio José 0b11866d83 Fix doc reference for headers type 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-16 21:35:21 -03:00