RequestHandlerMore.java

// init. disruptor event log translator.
BaseTranslator.EventLogTranslator eventLogValidationTranslator = new BaseTranslator.EventLogTranslator();

// handle http or tcp request.
Buffer body = ...
  
// get body from the request.
String json = new String(body.getBytes());

// set the values to event translator.
eventLogValidationTranslator.setVersion("1.0.0");
eventLogValidationTranslator.setEventType("page-view-event");
eventLogValidationTranslator.setValue(json);

// publish the event to validation disruptor.
validationDisruptor.publishEvent(this.eventLogValidationTranslator);

.