public class DmaapOutgoingMessageTest {
private DmaapOutgoingMessage dmaapOutgoingMessage;
+ private DmaapOutgoingMessage.Body body;
@Before
public void setUp() {
dmaapOutgoingMessage = new DmaapOutgoingMessage();
+ body = new DmaapOutgoingMessage.Body();
}
@Test
String expected = "DmaapOutgoingMessage{cambriaPartition='CambriaPartition', rpcName='rpcName', body=null}";
assertEquals(expected, dmaapOutgoingMessage.toString());
}
+
+ @Test
+ public void testOutput() {
+ body.setOutput("Output");
+ assertEquals("Output", body.getOutput());
+ }
}