import static org.hamcrest.Matchers.contains;
import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.util.Arrays;
import java.util.List;
import org.junit.Test;
*
* @author <a href="mailto:david.roden@bietr.de">David Roden</a>
*/
-public class FcpMessageTest {
+public class FcpMessageTest extends AbstractFcpMessageTest {
private final FcpMessage fcpMessage = new FcpMessage("TestMessage");
@Test
public void fcpMessageWithPayloadIsTerminatedByData() throws Exception {
fcpMessage.setPayloadInputStream(new ByteArrayInputStream("Test".getBytes()));
- ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
- fcpMessage.write(outputStream);
- List<String> lines = Arrays.asList(outputStream.toString().split("\r?\n"));
+ List<String> lines = encodeMessage(fcpMessage);
assertThat(lines, contains(
"TestMessage",
"Data",