SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-680 Add support for strict (or not) dependency on target-protocol header for CE

Browse Source 
Resolves #680
This commit is contained in:
Oleg Zhurakousky
2021-04-14 18:49:01 +02:00
parent 05907134f0
commit 15c58fd63f
3 changed files with 27 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
spring-cloud-function-context/src/test/java/org/springframework/cloud/function/cloudevent/CloudEventMessageUtilsAndBuilderTests.java
View File

@@ -31,6 +31,26 @@ import static org.assertj.core.api.Assertions.assertThat;
*/
public class CloudEventMessageUtilsAndBuilderTests {
@Test// see https://github.com/spring-cloud/spring-cloud-function/issues/680
public void testProperAttributeExtractionRegardlessOfTargetProtocol() {
Message<String> ceMessage = CloudEventMessageBuilder.withData("foo").build();
ceMessage = MessageBuilder.fromMessage(ceMessage).setHeader("target-protocol", "kafka").build();
String prefix = CloudEventMessageUtils.determinePrefixToUse(ceMessage.getHeaders());
assertThat(prefix).isEqualTo("ce-");
prefix = CloudEventMessageUtils.determinePrefixToUse(ceMessage.getHeaders(), true);
assertThat(prefix).isEqualTo("ce_");
String specVersion = CloudEventMessageUtils.getSpecVersion(ceMessage);
assertThat(specVersion).isEqualTo("1.0");
String type = CloudEventMessageUtils.getType(ceMessage);
assertThat(type).isEqualTo("java.lang.String");
String id = CloudEventMessageUtils.getId(ceMessage);
assertThat(id).isNotNull();
URI source = CloudEventMessageUtils.getSource(ceMessage);
assertThat(source.toString()).isEqualTo("https://spring.io/");
}
@Test
public void testAttributeRecognitionAndCanonicalization() {
Message<String> httpMessage = MessageBuilder.withPayload("hello")