cloudevents
/
sdk-java
mirror of https://github.com/cloudevents/sdk-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Typing the header's value 

Signed-off-by: Fabio José <fabiojose@gmail.com>
This commit is contained in:
Fabio José 2019-09-16 21:34:11 -03:00
parent d46300b57b
commit 14e873d3f2
4 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
api/src/test/java/io/cloudevents/v02/http/HeaderMapperTest.java
View File

@ -67,7 +67,7 @@ public class HeaderMapperTest {
Map<String, String> extensions = new HashMap<>();
// act
Map<String, Object> actual = HeaderMapper.map(attributes, extensions);
Map<String, String> actual = HeaderMapper.map(attributes, extensions);
//assert
assertFalse(actual.containsKey("ce-type"));
@ -85,7 +85,7 @@ public class HeaderMapperTest {
extensions.put("comexampleextension1", "value");
// act
Map<String, Object> actual = HeaderMapper.map(attributes, extensions);
Map<String, String> actual = HeaderMapper.map(attributes, extensions);
//assert
assertFalse(actual.containsKey("null-ext"));
@ -103,7 +103,7 @@ public class HeaderMapperTest {
extensions.put("comexampleextension1", "value");
// act
Map<String, Object> actual = HeaderMapper.map(attributes, extensions);
Map<String, String> actual = HeaderMapper.map(attributes, extensions);
//assert
assertFalse(actual.containsKey("Content-Type"));
@ -121,7 +121,7 @@ public class HeaderMapperTest {
extensions.put("comexampleextension1", "value");
// act
Map<String, Object> actual = HeaderMapper.map(attributes, extensions);
Map<String, String> actual = HeaderMapper.map(attributes, extensions);
//assert
assertTrue(actual.containsKey("comexampleextension1"));

6
api/src/test/java/io/cloudevents/v03/http/HeaderMapperTest.java
View File

@ -65,7 +65,7 @@ public class HeaderMapperTest {
Map<String, String> extensions = new HashMap<>();
// act
Map<String, Object> actual = HeaderMapper.map(attributes, extensions);
Map<String, String> actual = HeaderMapper.map(attributes, extensions);
//assert
assertFalse(actual.containsKey("ce-type"));
@ -83,7 +83,7 @@ public class HeaderMapperTest {
extensions.put("comexampleextension1", "value");
// act
Map<String, Object> actual = HeaderMapper.map(attributes, extensions);
Map<String, String> actual = HeaderMapper.map(attributes, extensions);
//assert
assertFalse(actual.containsKey("ce-null-ext"));
@ -101,7 +101,7 @@ public class HeaderMapperTest {
extensions.put("comexampleextension1", "value");
// act
Map<String, Object> actual = HeaderMapper.map(attributes, extensions);
Map<String, String> actual = HeaderMapper.map(attributes, extensions);
//assert
assertFalse(actual.containsKey("Content-Type"));

4
kafka/src/main/java/io/cloudevents/v02/kafka/HeaderMapper.java
View File

@ -50,12 +50,12 @@ public class HeaderMapper {
* {@link ExtensionFormat#marshal(java.util.Collection)}
* @return The map of Kafka Headers with values as {@code byte[]}
*/
public static Map<String, Object> map(Map<String, String> attributes,
public static Map<String, byte[]> map(Map<String, String> attributes,
Map<String, String> extensions) {
Objects.requireNonNull(attributes);
Objects.requireNonNull(extensions);
Map<String, Object> result = attributes.entrySet()
Map<String, byte[]> result = attributes.entrySet()
.stream()
.filter(attribute -> null!= attribute.getValue())
.map(attribute ->

10
kafka/src/test/java/io/cloudevents/v02/kafka/HeaderMapperTest.java
View File

@ -62,7 +62,7 @@ public class HeaderMapperTest {
Map<String, String> extensions = new HashMap<>();
// act
Map<String, Object> actual = HeaderMapper.map(attributes, extensions);
Map<String, byte[]> actual = HeaderMapper.map(attributes, extensions);
//assert
assertFalse(actual.containsKey("ce-type"));
@ -80,7 +80,7 @@ public class HeaderMapperTest {
extensions.put("comexampleextension1", "value");
// act
Map<String, Object> actual = HeaderMapper.map(attributes, extensions);
Map<String, byte[]> actual = HeaderMapper.map(attributes, extensions);
//assert
assertFalse(actual.containsKey("null-ext"));
@ -98,7 +98,7 @@ public class HeaderMapperTest {
extensions.put("comexampleextension1", "value");
// act
Map<String, Object> actual = HeaderMapper.map(attributes, extensions);
Map<String, byte[]> actual = HeaderMapper.map(attributes, extensions);
//assert
assertFalse(actual.containsKey("Content-Type"));
@ -116,7 +116,7 @@ public class HeaderMapperTest {
extensions.put("comexampleextension1", "value");
// act
Map<String, Object> actual = HeaderMapper.map(attributes, extensions);
Map<String, byte[]> actual = HeaderMapper.map(attributes, extensions);
//assert
assertTrue(actual.containsKey("comexampleextension1"));
@ -134,7 +134,7 @@ public class HeaderMapperTest {
extensions.put("comexampleextension1", "value");
// act
Map<String, Object> actuals = HeaderMapper.map(attributes, extensions);
Map<String, byte[]> actuals = HeaderMapper.map(attributes, extensions);
// assert
actuals.values()