@@ -0,0 +1,1118 @@
+package net.openhft.chronicle.wire.monitoring;%0A%0Aimport net.openhft.chronicle.bytes.Bytes;%0Aimport net.openhft.chronicle.core.time.SystemTimeProvider;%0Aimport net.openhft.chronicle.wire.AbstractMarshallable;%0Aimport net.openhft.chronicle.wire.JSONWire;%0Aimport net.openhft.chronicle.wire.LongConversion;%0Aimport net.openhft.chronicle.wire.MicroTimestampLongConverter;%0A%0Apublic class MonitorSample extends AbstractMarshallable %7B%0A    // id for the stream%0A    String id;%0A    // timestamtp in microseconds%0A    @LongConversion(MicroTimestampLongConverter.class)%0A    long ts;%0A    // latencies in microseconds.%0A    long p50, p90, p99;%0A%0A    public static void main(String%5B%5D args) %7B%0A        MonitorSample ms = new MonitorSample();%0A        ms.id = %22order-sent%22;%0A        ms.ts = SystemTimeProvider.INSTANCE.currentTimeMicros();%0A        ms.p50 = 35;%0A        ms.p90 = 67;%0A        ms.p99 = 131;%0A%0A        JSONWire w = new JSONWire(Bytes.elasticByteBuffer());%0A        w.getValueOut().object(ms);%0A        // prints%0A        // %22id%22:%22order-sent%22,%22ts%22:%222019-11-26T12:29:47.178%22,%22p50%22:35,%22p90%22:67,%22p99%22:131%0A        System.out.println(w);%0A    %7D%0A%7D%0A

Add sample monitoring message