@Test
public void testTimestamp() throws KeyTypeNotImplementedException
{

  String randomValue = RngUtils.randomString(20);
  ByteBuffer serializationBuffer = ByteBuffer.allocate(1000).order(_eventV1Factory.getByteOrder());
  DbusEventInfo eventInfo =  new DbusEventInfo(DbusOpcode.UPSERT, 0L, (short)0, partitionId, timeStamp, srcId,
                                               schemaId, randomValue.getBytes(Charset.defaultCharset()), false, false);
  eventInfo.setEventSerializationVersion(DbusEventFactory.DBUS_EVENT_V1);  // make this explicit
  DbusEventFactory.serializeEvent(new DbusEventKey(key), serializationBuffer, eventInfo);
  DbusEventInternalReadable e = _eventV1Factory.createReadOnlyDbusEventFromBuffer(serializationBuffer, 0);
  assertEquals("Timestamp matches", timeStamp,e.timestampInNanos());
}