class DeserializerProcessor extends MonitoredProcess {

  public DeserializedEvent deserialize(String eventString) {
    DeserializedEvent dEvent = null;
    this.getRuntimeStat().start();

    try {
      dEvent = this.deser.deserialize(eventString);
      this.getSuccessCountStat().increment();
    } catch (DeserializationException e) {
      logger.warn("failed to deserialize", e);
      this.getErrorCountStat().increment();
    } finally {
      this.getRuntimeStat().stop();
    }

    return dEvent;
  }

  public  DeserializerProcessor(Deserializer deserializer);

}