From 0ca7573cc5303fb52adfba2b343c29fc2218de17 Mon Sep 17 00:00:00 2001 From: Toshiaki Maki Date: Wed, 23 Nov 2016 21:00:13 +0900 Subject: [PATCH] Fix broken MessageConverter definition Fix wrong argument in setSchemaLocation --- .../main/asciidoc/spring-cloud-stream-overview.adoc | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc b/spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc index 8fdda957d..540f9ec8c 100644 --- a/spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc +++ b/spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc @@ -1196,9 +1196,8 @@ public static class SinkApplication { ... @Bean - public MessageConverter userMessageConverter() throws IOException { - AvroSchemaMessageConverter avroSchemaMessageConverter { - return new AvroSchemaMessageConverter(MimeType.valueOf("avro/bytes"); + public MessageConverter userMessageConverter() { + return new AvroSchemaMessageConverter(MimeType.valueOf("avro/bytes")); } } ---- @@ -1214,10 +1213,9 @@ public static class SinkApplication { ... @Bean - public MessageConverter userMessageConverter() throws IOException { - AvroSchemaMessageConverter avroSchemaMessageConverter { - MessageConverter converter = new AvroSchemaMessageConverter(MimeType.valueOf("avro/bytes"); - converter.setSchemaLocation("classpath:schemas/User.avro"); + public MessageConverter userMessageConverter() { + AvroSchemaMessageConverter converter = new AvroSchemaMessageConverter(MimeType.valueOf("avro/bytes")); + converter.setSchemaLocation(new ClassPathResource("schemas/User.avro")); return converter; } }