java类com.mongodb.reactivestreams.client.MongoClients的实例源码-面圈网

ShardSetFinder.java 文件源码项目：flink-mingo-tail 阅读 35 收藏 0 点赞 0 评论 0

private List<MongoClientWrapper> getMongoClient(List<ConnectionString> shardSet) {
   mongoClients = new ArrayList<>();
   try {
      for (ConnectionString address : shardSet) {
         com.mongodb.reactivestreams.client.MongoClient client = MongoClients.create(address);
         mongoClients.add(new MongoClientWrapper(address.getConnectionString(), client));
         Thread.sleep(100); // allow the client to establish prior to being
      }
   } catch (InterruptedException e) {
      e.printStackTrace();
   }
   return mongoClients;
}

Fixture.java 文件源码项目：mongo-java-driver-reactivestreams 阅读 27 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：spring5demo 阅读 38 收藏 0 点赞 0 评论 0

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

MongoConfig.java 文件源码项目：Spring-5.0-Cookbook 阅读 33 收藏 0 点赞 0 评论 0

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

MongoConfig.java 文件源码项目：spring-reactive-sample 阅读 26 收藏 0 点赞 0 评论 0

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

MongoConfig.java 文件源码项目：spring-reactive-sample 阅读 30 收藏 0 点赞 0 评论 0

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

MongoConfig.java 文件源码项目：spring-reactive-sample 阅读 26 收藏 0 点赞 0 评论 0

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

MongoConfig.java 文件源码项目：spring-reactive-sample 阅读 28 收藏 0 点赞 0 评论 0

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

MongoConfig.java 文件源码项目：spring-reactive-sample 阅读 34 收藏 0 点赞 0 评论 0

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

MongoConfig.java 文件源码项目：spring-reactive-sample 阅读 37 收藏 0 点赞 0 评论 0

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

ApplicationConfiguration.java 文件源码项目：spring-react-one 阅读 33 收藏 0 点赞 0 评论 0

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

ApplicationConfiguration.java 文件源码项目：spring-data-examples 阅读 38 收藏 0 点赞 0 评论 0

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

MongoDbConfiguration.java 文件源码项目：AngularAndSpring 阅读 30 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：reactive-spring5-example 阅读 31 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：docker-workshop 阅读 27 收藏 0 点赞 0 评论 0

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

WebfluxTwitterDemoApplication.java 文件源码项目：webflux-twitter-demo 阅读 24 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：openshift-workshop 阅读 27 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：openshift-workshop 阅读 34 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：openshift-workshop 阅读 33 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：openshift-workshop 阅读 31 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：openshift-workshop 阅读 26 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：openshift-workshop 阅读 37 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：openshift-workshop 阅读 28 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：openshift-workshop 阅读 32 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：openshift-workshop 阅读 34 收藏 0 点赞 0 评论 0

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

ApplicationConfiguration.java 文件源码项目：whats-new-in-spring-data 阅读 39 收藏 0 点赞 0 评论 0

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

MongoConfiguration.java 文件源码项目：spring-reactive-playground 阅读 38 收藏 0 点赞 0 评论 0

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