diff --git a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/MessageConverterTests.java b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/MessageConverterTests.java index 55e591966..d426a1a26 100644 --- a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/MessageConverterTests.java +++ b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/MessageConverterTests.java @@ -16,6 +16,8 @@ package org.springframework.cloud.stream.binder; +import java.nio.BufferUnderflowException; + import org.junit.Assert; import org.junit.Test; @@ -112,19 +114,9 @@ public class MessageConverterTests { assertThat(new String(embedded).substring(1)).isEqualTo("\u0001\u0003foo\u0000\u0000\u0000\u0005\"bar\"Hello"); } - @Test - public void testCanDecodeOldFormat() throws Exception { - byte[] bytes = "\u0002\u0003foo\u0003bar\u0003baz\u0004quxxHello".getBytes("UTF-8"); - Message message = new GenericMessage<>(bytes); - MessageValues extracted = EmbeddedHeaderUtils.extractHeaders(message, false); - assertThat(new String((byte[]) extracted.getPayload())).isEqualTo("Hello"); - assertThat(extracted.get("foo")).isEqualTo("bar"); - assertThat(extracted.get("baz")).isEqualTo("quxx"); - } - @Test public void testBadDecode() throws Exception { - byte[] bytes = "\u0002\u0003foo\u0020bar\u0003baz\u0004quxxHello".getBytes("UTF-8"); + byte[] bytes = new byte[] { (byte) 0xff, 99 }; Message message = new GenericMessage<>(bytes); try { EmbeddedHeaderUtils.extractHeaders(message, false); @@ -132,10 +124,9 @@ public class MessageConverterTests { } catch (Exception e) { String s = EmbeddedHeaderUtils.decodeExceptionMessage(message); - assertThat(e).isInstanceOf(StringIndexOutOfBoundsException.class); - assertThat(s).startsWith("Could not convert message: 0203666F6F"); + assertThat(e).isInstanceOf(BufferUnderflowException.class); + assertThat(s).startsWith("Could not convert message: FF63"); } - } }