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

Cleanup original content type in test

Browse Source
This commit is contained in:
Soby Chacko
2019-10-24 09:43:23 -04:00
parent 803b059cd1
commit 9bce943106
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-schema-registry-client/src/test/java/org/springframework/cloud/schema/serialization/AvroMessageConverterSerializationTests.java
View File

@@ -50,7 +50,6 @@ import org.springframework.cloud.schema.registry.avro.AvroSchemaServiceManagerIm
import org.springframework.cloud.schema.registry.avro.DefaultSubjectNamingStrategy;
import org.springframework.cloud.schema.registry.client.DefaultSchemaRegistryClient;
import org.springframework.cloud.schema.registry.client.SchemaRegistryClient;
import org.springframework.cloud.stream.binder.BinderHeaders;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.integration.support.MutableMessageHeaders;
@@ -178,7 +177,6 @@ public class AvroMessageConverterSerializationTests {
assertThat(genericRef.getVersion()).isEqualTo(1);
}
/**
public void testOriginalContentTypeHeaderOnly() throws Exception {
User specificRecord = new User();
specificRecord.setName("joe");
@@ -201,15 +199,13 @@ public class AvroMessageConverterSerializationTests {
Message source = MessageBuilder.withPayload(baos.toByteArray())
.setHeader(MessageHeaders.CONTENT_TYPE,
MimeTypeUtils.APPLICATION_OCTET_STREAM)
.setHeader(BinderHeaders.BINDER_ORIGINAL_CONTENT_TYPE,
"application/vnd.user.v1+avro")
.build();
Object converted = converter.fromMessage(source, User.class);
assertThat(converted).isNotNull();
assertThat(specificRecord.getName().toString())
.isEqualTo(((User) converted).getName().toString());
}
**/
private SchemaReference extractSchemaReference(MimeType mimeType) {
SchemaReference schemaReference = null;