publishEvent((Event) o);
log.info("Published event {}: {}", o, ((Event) o).getLogMessage());
}else if (o instanceof Messages.EventWrapper) {
storeEvent((Messages.EventWrapper) o);
publishEvent((Messages.EventWrapper) o);
<BUG>log.info("Published event {}: {}", o, ((Event) o).getLogMessage());
} else if (o instanceof RetreiveAggregateEvents) {</BUG>
readAggregateEvents((RetreiveAggregateEvents) o);
} else if (o instanceof AcknowledgePreviousEventsProcessed) {
<BUG>sender().tell(new Success(), self());
} else if (o instanceof UpgradeAggregate) {</BUG>
UpgradeAggregate upgrade = (UpgradeAggregate) o;

publishEvent((Event) o);
log.info("Published event {}: {}", o, ((Event) o).getLogMessage());
}else if (o instanceof Messages.EventWrapper) {
storeEvent((Messages.EventWrapper) o);
publishEvent((Messages.EventWrapper) o);
log.info("Published event {}", o);
} else if (o instanceof RetreiveAggregateEvents) {
readAggregateEvents((RetreiveAggregateEvents) o);
} else if (o instanceof AcknowledgePreviousEventsProcessed) {
sender().tell(new Success(), self());
} else if (o instanceof Messages.AcknowledgePreviousEventsProcessed) {
sender().tell(Messages.Success.getDefaultInstance(), self());
} else if (o instanceof UpgradeAggregate) {
UpgradeAggregate upgrade = (UpgradeAggregate) o;
