+ @Test
+ public void testMessageParsing() {
+ String message = dmaapInputMessage(Operation.DELETE);
+ System.out.println(message);
+ DmaapRequestMessage parsedMessage = gson.fromJson(message, ImmutableDmaapRequestMessage.class);
+ assertTrue(parsedMessage != null);
+ assertFalse(parsedMessage.payload().isPresent());
+
+ message = dmaapInputMessage(Operation.PUT);
+ System.out.println(message);
+ parsedMessage = gson.fromJson(message, ImmutableDmaapRequestMessage.class);
+ assertTrue(parsedMessage != null);
+ assertTrue(parsedMessage.payload().isPresent());
+ }
+