private final FcpMessage fcpMessage = new FcpMessage("TestMessage");
@Test
public void fcpMessageWithPayloadIsTerminatedByData() throws Exception {
fcpMessage.setPayloadInputStream(new ByteArrayInputStream("Test".getBytes()));
private final FcpMessage fcpMessage = new FcpMessage("TestMessage");
@Test
public void fcpMessageWithPayloadIsTerminatedByData() throws Exception {
fcpMessage.setPayloadInputStream(new ByteArrayInputStream("Test".getBytes()));