类com.mongodb.event.CommandListener源码实例Demo

下面列出了怎么用com.mongodb.event.CommandListener的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: ditto   文件: MongoClientWrapper.java
@Override
public MongoClientWrapperBuilder addCommandListener(@Nullable final CommandListener commandListener) {
    if (null != commandListener) {
        mongoClientSettingsBuilder.addCommandListener(commandListener);
    }
    return this;
}
 
@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));
}
 
源代码3 项目: brave   文件: MongoDBTracingTest.java
@Test public void commandListener_returnsTraceMongoCommandListener() {
  Tracer tracer = mock(Tracer.class);
  when(tracing.tracer()).thenReturn(tracer);

  CommandListener listener = MongoDBTracing.newBuilder(tracing).build().commandListener();
  assertThat(listener).isInstanceOf(TraceMongoCommandListener.class);
  assertThat(listener).extracting("threadLocalSpan").extracting("tracer").isEqualTo(tracer);
}
 
源代码4 项目: ditto   文件: SearchRootActor.java
@Nullable
private static CommandListener getCommandListenerOrNull(final MongoDbConfig.MonitoringConfig monitoringConfig) {
    return monitoringConfig.isCommandsEnabled() ? new KamonCommandListener(KAMON_METRICS_PREFIX) : null;
}
 
源代码5 项目: ditto   文件: SearchUpdaterRootActor.java
@Nullable
private static CommandListener getCommandListenerOrNull(final MongoDbConfig.MonitoringConfig monitoringConfig) {
    return monitoringConfig.isCommandsEnabled() ? new KamonCommandListener(KAMON_METRICS_PREFIX) : null;
}
 
源代码6 项目: brave   文件: MongoDBTracing.java
public CommandListener commandListener() {
  return new TraceMongoCommandListener(this);
}
 
源代码7 项目: ditto   文件: DittoMongoClientBuilder.java
/**
 * Adds a custom CommandListener.
 *
 * @param commandListener the listener to be added.
 * @return this builder instance to allow method chaining.
 */
GeneralPropertiesStep addCommandListener(@Nullable CommandListener commandListener);
 
 类所在包
 类方法
 同包方法