EventMessageDecoder implements MetadataDecoder { @SuppressWarnings("ByteBufferBackingArray") @Override public Metadata decode(MetadataInputBuffer inputBuffer) { ByteBuffer buffer = Assertions.checkNotNull(inputBuffer.data); byte[] data = buffer.array(); int size = buffer.limit(); return new Metadata(decode(new ParsableByteArray(data, size))); }  @SuppressWarnings("ByteBufferBackingArray") @Override Metadata decode(MetadataInputBuffer inputBuffer); EventMessage decode(ParsableByteArray emsgData);  }
@Test public void testDecodeEventMessage() { byte[] rawEmsgBody = joinByteArrays( createByteArray(117, 114, 110, 58, 116, 101, 115, 116, 0), createByteArray(49, 50, 51, 0), createByteArray(0, 0, 11, 184), createByteArray(0, 15, 67, 211), createByteArray(0, 1, 2, 3, 4)); EventMessageDecoder decoder = new EventMessageDecoder(); MetadataInputBuffer buffer = new MetadataInputBuffer(); buffer.data = ByteBuffer.allocate(rawEmsgBody.length).put(rawEmsgBody); Metadata metadata = decoder.decode(buffer); assertThat(metadata.length()).isEqualTo(1); EventMessage eventMessage = (EventMessage) metadata.get(0); assertThat(eventMessage.schemeIdUri).isEqualTo("urn:test"); assertThat(eventMessage.value).isEqualTo("123"); assertThat(eventMessage.durationMs).isEqualTo(3000); assertThat(eventMessage.id).isEqualTo(1000403); assertThat(eventMessage.messageData).isEqualTo(new byte[]{0, 1, 2, 3, 4}); }