Java 类com.mongodb.reactivestreams.client.MongoClient 实例源码

项目：mongo-java-driver-reactivestreams 文件：Fixture.java

public static synchronized MongoClient getMongoClient() {
    if (mongoClient == null) {
        mongoClient = MongoClients.create(getConnectionString());
        Runtime.getRuntime().addShutdownHook(new ShutdownHook());
    }
    return mongoClient;
}

项目：spring5demo 文件：MongoConfiguration.java

@Override
public MongoClient mongoClient() {
    return MongoClients.create(String.format("mongodb://%s:%d", mongoProperties.getHost(), mongoProperties.getPort()));
}

项目：Spring-5.0-Cookbook 文件：MongoConfig.java

@Override
public MongoClient mongoClient() {
    return MongoClients.create();
}

项目：spring-reactive-sample 文件：MongoConfig.java

@Override
public MongoClient reactiveMongoClient() {
    return MongoClients.create(mongoUri);
}

项目：spring-reactive-sample 文件：MongoConfig.java

@Override
public MongoClient reactiveMongoClient() {
    return MongoClients.create(mongoUri);
}

项目：spring-reactive-sample 文件：MongoConfig.java

@Override
public MongoClient reactiveMongoClient() {
    return MongoClients.create(mongoUri);
}

项目：spring-reactive-sample 文件：MongoConfig.java

@Override
public MongoClient reactiveMongoClient() {
    return MongoClients.create(mongoUri);
}

项目：spring-reactive-sample 文件：MongoConfig.java

@Override
public MongoClient reactiveMongoClient() {
    return MongoClients.create(mongoUri);
}

项目：spring-reactive-sample 文件：MongoConfig.java

@Override
public MongoClient reactiveMongoClient() {
    return MongoClients.create(mongoUri);
}

项目：spring-react-one 文件：ApplicationConfiguration.java

public MongoClient mongoClient() {
    return MongoClients.create(String.format("mongodb://localhost:%d", mongoProperties.getPort()));
}

项目：spring-data-examples 文件：ApplicationConfiguration.java

@Override
@Bean
@DependsOn("embeddedMongoServer")
public MongoClient mongoClient() {
    return MongoClients.create(String.format("mongodb://localhost:%d", mongoProperties.getPort()));
}

项目：AngularAndSpring 文件：MongoDbConfiguration.java

@Override
public MongoClient reactiveMongoClient() {
    return MongoClients.create("mongodb://localhost/"+getDatabaseName());
}

项目：reactive-spring5-example 文件：MongoConfiguration.java

@Override
public MongoClient mongoClient() {
    return MongoClients.create();
}

项目：docker-workshop 文件：MongoConfiguration.java

@Override
public MongoClient mongoClient() {
  return MongoClients.create(url);
}

项目：webflux-twitter-demo 文件：WebfluxTwitterDemoApplication.java

@Override
public MongoClient mongoClient() {
    // this assumes your MongoDB is running on the default port, i.e. 27017
    return MongoClients.create();
}

项目：openshift-workshop 文件：MongoConfiguration.java

@Override
public MongoClient reactiveMongoClient() {
  return MongoClients.create(url);
}

项目：openshift-workshop 文件：MongoConfiguration.java

@Override
public MongoClient reactiveMongoClient() {
  return MongoClients.create(url);
}

项目：openshift-workshop 文件：MongoConfiguration.java

@Override
public MongoClient reactiveMongoClient() {
  return MongoClients.create(url);
}

项目：openshift-workshop 文件：MongoConfiguration.java

@Override
public MongoClient reactiveMongoClient() {
  return MongoClients.create(url);
}

项目：openshift-workshop 文件：MongoConfiguration.java

@Override
public MongoClient reactiveMongoClient() {
  return MongoClients.create(url);
}

项目：openshift-workshop 文件：MongoConfiguration.java

@Override
public MongoClient reactiveMongoClient() {
  return MongoClients.create(url);
}

项目：openshift-workshop 文件：MongoConfiguration.java

@Override
public MongoClient reactiveMongoClient() {
  return MongoClients.create(url);
}

项目：openshift-workshop 文件：MongoConfiguration.java

@Override
public MongoClient reactiveMongoClient() {
  return MongoClients.create(url);
}

项目：openshift-workshop 文件：MongoConfiguration.java

@Override
public MongoClient reactiveMongoClient() {
  return MongoClients.create(url);
}

项目：flink-mingo-tail 文件：MongoClientWrapper.java

public MongoClientWrapper(String host, MongoClient client) {
   this.host = host;
   this.client = client;
}

项目：flink-mingo-tail 文件：MongoClientWrapper.java

public MongoClient getClient() {
   return client;
}

项目：whats-new-in-spring-data 文件：ApplicationConfiguration.java

@Bean
MongoClient mongoClient() {
    return MongoClients.create();
}

项目：whats-new-in-spring-data 文件：ApplicationConfiguration.java

@Bean
MongoDatabase mongoDatabase(MongoClient mongoClient) {
    return mongoClient.getDatabase(database);
}

项目：whats-new-in-spring-data 文件：ApplicationConfiguration.java

@Bean
ReactiveMongoDbFactory reactiveMongoDbFactory(MongoClient mongoClient) {
    return new ReactiveMongoDbFactory(mongoClient, database);
}

项目：spring-reactive-playground 文件：MongoConfiguration.java

@Override
public MongoClient mongoClient() {
    return MongoClients.create();
}

项目：nightclazz-spring5 文件：WebmvcConfig.java

/**
 * Builds a template that will be used to query the Mongo database.
 * @param mongoClient the mongo client
 * @return the bean
 */
@Bean
public ReactiveMongoTemplate reactiveMongoTemplate(final MongoClient mongoClient) {
    return new ReactiveMongoTemplate(mongoClient, "nightclazz");
}

项目：nightclazz-spring5 文件：ReactiveDrawingControllerConfig.java

/**
 * Builds a low level template that will be used to create tailable cursors MongoDB.
 *
 * @param mongoClient the mongo client
 * @return the new bean
 */
@Bean
public ReactiveMongoTemplate reactiveMongoTemplate(final MongoClient mongoClient) {
    return new ReactiveMongoTemplate(mongoClient, "nightclazz");
}

项目：mongo-java-driver-reactivestreams 文件：MongoClientImpl.java

/**
 * The internal MongoClientImpl constructor.
 *
 * <p>This should not be considered a part of the public API.</p>
 * @param wrapped the underlying MongoClient
 */
public MongoClientImpl(final com.mongodb.async.client.MongoClient wrapped) {
    this.wrapped = notNull("wrapped", wrapped);
}