@Override
public void commandSucceeded(final CommandSucceededEvent event) {
    if (LOGGER.isDebugEnabled()) {
        LOGGER.debug("Successfully executed command '{}' with id {} "
                        + "on connection '{}' to server '{}' after {}ms",
                event.getCommandName(),
                event.getRequestId(),
                event.getConnectionDescription().getConnectionId(),
                event.getConnectionDescription().getServerAddress(),
                event.getElapsedTime(TimeUnit.MILLISECONDS));
    }

    final long elapsedTime = event.getElapsedTime(TimeUnit.NANOSECONDS);
    final String commandName = event.getCommandName();
    recordElapsedTime(elapsedTime, commandName);
}
 

@Override
public void customize(MongoClientSettings.Builder clientSettingsBuilder) {
	super.customize(clientSettingsBuilder);
	CommandListener listener = clientSettingsBuilder.build().getCommandListeners()
			.get(0);
	listener.commandStarted(new CommandStartedEvent(0, null, "", "",
			BDDMockito.mock(BsonDocument.class)));
	listener.commandSucceeded(new CommandSucceededEvent(1, null, "",
			BDDMockito.mock(BsonDocument.class), 100));
}
 

CommandSucceededEvent createCommandSucceededEvent() {
  return new CommandSucceededEvent(
    1,
    createConnectionDescription(),
    "insert",
    new BsonDocument(),
    1000
  );
}
 

@Override public void commandSucceeded(CommandSucceededEvent event) {
  Span span = threadLocalSpan.remove();
  if (span == null) return;
  span.finish();
}