本文整理了Java中io.vertx.ext.mongo.MongoClient.createShared()方法的一些代码示例，展示了MongoClient.createShared()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。MongoClient.createShared()方法的具体详情如下：
包路径：io.vertx.ext.mongo.MongoClient
类名称：MongoClient
方法名：createShared

MongoClient.createShared介绍

暂无

代码示例

代码示例来源：origin: vert-x3/vertx-examples

.put("db_name", db);
MongoClient mongoClient = MongoClient.createShared(vertx, mongoconfig);

代码示例来源：origin: vert-x3/vertx-examples

MongoClient mongo = MongoClient.createShared(vertx, config);

代码示例来源：origin: vert-x3/vertx-examples

final MongoClient mongo = MongoClient.createShared(vertx, new JsonObject().put("db_name", "demo"));

代码示例来源：origin: vert-x3/vertx-examples

mongo = MongoClient.createShared(vertx, new JsonObject().put("db_name", "demo"));

代码示例来源：origin: vert-x3/vertx-examples

mongo = MongoClient.createShared(vertx, new JsonObject().put("db_name", "demo"));

代码示例来源：origin: cescoffier/vertx-workshop

public DataStorageServiceImpl(Vertx vertx, JsonObject config) {
 this.mongo = MongoClient.createShared(vertx, config, "places");
 this.vertx = vertx;
 LOGGER.info("Data Storage Service instantiated");
}

代码示例来源：origin: cescoffier/vertx-workshop

private void populateDatabase(Collection<Place> places) {
 MongoClient mongo = MongoClient.createShared(vertx,
   new JsonObject().put("db_name", "places").put("connection_string", mongoURL),
   "places");
 places.stream().forEach(place ->
   mongo.insert("places", place.toJson(), result -> {
    if (result.failed()) {
     System.err.println("I was not able to insert '" + place.getName() + "' : " + result.cause().getMessage());
    } else {
     System.out.println("Place '" + place.getName() + "' inserted");
    }
   }));
}

代码示例来源：origin: io.vertx/vertx-auth-mongo

@Override
public MongoAuth createProvider(Vertx vertx) {
 MongoClient client;
 if (shared) {
  if (datasourceName != null) {
   client = MongoClient.createShared(vertx, config, datasourceName);
  } else {
   client = MongoClient.createShared(vertx, config);
  }
 } else {
  client = MongoClient.createNonShared(vertx, config);
 }
 JsonObject authConfig = new JsonObject();
 MongoAuthOptionsConverter.toJson(this, authConfig);
 return MongoAuth.create(client, authConfig);
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Like {@link io.vertx.rxjava.ext.mongo.MongoClient#createShared} but with the default data source name
 * @param vertx the Vert.x instance
 * @param config the configuration
 * @return the client
 */
public static io.vertx.rxjava.ext.mongo.MongoClient createShared(io.vertx.rxjava.core.Vertx vertx, JsonObject config) { 
 io.vertx.rxjava.ext.mongo.MongoClient ret = io.vertx.rxjava.ext.mongo.MongoClient.newInstance(io.vertx.ext.mongo.MongoClient.createShared(vertx.getDelegate(), config));
 return ret;
}

代码示例来源：origin: silentbalanceyh/vertx-zero

private static void initInternal(final Vertx vertx,
                 final String name) {
  Fn.pool(CLIENTS, name,
      () -> Infix.init(Plugins.Infix.MONGO,
          (config) -> MongoClient.createShared(vertx, config, name),
          MongoInfix.class));
}

代码示例来源：origin: cn.vertxup/vertx-up

private static void initInternal(final Vertx vertx,
                 final String name) {
  Fn.pool(CLIENTS, name,
      () -> Infix.init(Plugins.Infix.MONGO,
          (config) -> MongoClient.createShared(vertx, config, name),
          MongoInfix.class));
}

代码示例来源：origin: vert-x3/vertx-rx

/**
 * Create a Mongo client which shares its data source with any other Mongo clients created with the same
 * data source name
 * @param vertx the Vert.x instance
 * @param config the configuration
 * @param dataSourceName the data source name
 * @return the client
 */
public static io.vertx.rxjava.ext.mongo.MongoClient createShared(io.vertx.rxjava.core.Vertx vertx, JsonObject config, String dataSourceName) { 
 io.vertx.rxjava.ext.mongo.MongoClient ret = io.vertx.rxjava.ext.mongo.MongoClient.newInstance(io.vertx.ext.mongo.MongoClient.createShared(vertx.getDelegate(), config, dataSourceName));
 return ret;
}

代码示例来源：origin: folio-org/okapi

protected MongoHandle(Vertx vertx, JsonObject conf) {
 JsonObject opt = new JsonObject();
 String h = Config.getSysConf("mongo_host", "localhost", conf);
 if (!h.isEmpty()) {
  opt.put("host", h);
 }
 String p = Config.getSysConf("mongo_port", "27017", conf);
 if (!p.isEmpty()) {
  opt.put("port", Integer.parseInt(p));
 }
 String dbName = Config.getSysConf("mongo_db_name", "", conf);
 if (!dbName.isEmpty()) {
  opt.put("db_name", dbName);
 }
 logger.info("Using mongo backend at " + h + " : " + p + " / " + dbName);
 this.cli = MongoClient.createShared(vertx, opt);
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Create a Mongo client which shares its data source with any other Mongo clients created with the same
 * data source name
 * @param vertx the Vert.x instance
 * @param config the configuration
 * @param dataSourceName the data source name
 * @return the client
 */
public static io.vertx.rxjava.ext.mongo.MongoClient createShared(io.vertx.rxjava.core.Vertx vertx, JsonObject config, String dataSourceName) { 
 io.vertx.rxjava.ext.mongo.MongoClient ret = io.vertx.rxjava.ext.mongo.MongoClient.newInstance(io.vertx.ext.mongo.MongoClient.createShared(vertx.getDelegate(), config, dataSourceName));
 return ret;
}

代码示例来源：origin: io.vertx/vertx-lang-groovy

public static io.vertx.ext.mongo.MongoClient createShared(io.vertx.ext.mongo.MongoClient j_receiver, io.vertx.core.Vertx vertx, java.util.Map<String, Object> config, java.lang.String dataSourceName) {
 return io.vertx.core.impl.ConversionHelper.fromObject(io.vertx.ext.mongo.MongoClient.createShared(vertx,
  config != null ? io.vertx.core.impl.ConversionHelper.toJsonObject(config) : null,
  dataSourceName));
}
public static io.vertx.ext.mongo.MongoClient createShared(io.vertx.ext.mongo.MongoClient j_receiver, io.vertx.core.Vertx vertx, java.util.Map<String, Object> config) {

代码示例来源：origin: io.vertx/vertx-lang-groovy

public static io.vertx.ext.mongo.MongoClient createShared(io.vertx.ext.mongo.MongoClient j_receiver, io.vertx.core.Vertx vertx, java.util.Map<String, Object> config) {
  return io.vertx.core.impl.ConversionHelper.fromObject(io.vertx.ext.mongo.MongoClient.createShared(vertx,
   config != null ? io.vertx.core.impl.ConversionHelper.toJsonObject(config) : null));
 }
}

代码示例来源：origin: vert-x3/vertx-rx

/**
 * Like {@link io.vertx.rxjava.ext.mongo.MongoClient#createShared} but with the default data source name
 * @param vertx the Vert.x instance
 * @param config the configuration
 * @return the client
 */
public static io.vertx.rxjava.ext.mongo.MongoClient createShared(io.vertx.rxjava.core.Vertx vertx, JsonObject config) { 
 io.vertx.rxjava.ext.mongo.MongoClient ret = io.vertx.rxjava.ext.mongo.MongoClient.newInstance(io.vertx.ext.mongo.MongoClient.createShared(vertx.getDelegate(), config));
 return ret;
}

代码示例来源：origin: io.vertx/vertx-auth-mongo

private void initMongoClient() throws Exception {
 CountDownLatch latch = new CountDownLatch(1);
 System.out.println(getConfig().encode());
 mongoClient = MongoClient.createShared(vertx, getConfig());
 dropCollections(latch);
 awaitLatch(latch);
}

代码示例来源：origin: io.vertx/vertx-service-discovery

@Override
public MongoClient retrieve() {
 JsonObject result = record().getMetadata().copy();
 result.mergeIn(record().getLocation());
 if (config != null) {
  result.mergeIn(config);
 }
 if (result.getBoolean("shared", false)) {
  return MongoClient.createShared(vertx, result);
 } else {
  return MongoClient.createNonShared(vertx, result);
 }
}

代码示例来源：origin: vert-x3/vertx-service-discovery

@Override
public MongoClient retrieve() {
 JsonObject result = record().getMetadata().copy();
 result.mergeIn(record().getLocation());
 if (config != null) {
  result.mergeIn(config);
 }
 if (result.getBoolean("shared", false)) {
  return MongoClient.createShared(vertx, result);
 } else {
  return MongoClient.createNonShared(vertx, result);
 }
}