public void run() {
try {
commandBus.dispatch(asCommandMessage(new UpdateStubAggregateCommand(aggregateId)));
commandBus.dispatch(asCommandMessage(new ProblematicCommand(aggregateId)),
SilentCallback.INSTANCE);
commandBus.dispatch(asCommandMessage(new LoopingCommand(aggregateId)));
counter.incrementAndGet();
} catch (Exception ex) {
throw new RuntimeException(ex);
}
}