io.vertx.servicediscovery.Record.getRegistration()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(8.2k)|赞(0)|评价(0)|浏览(77)

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

Record.getRegistration介绍

[英]Gets the registration id if any. Getting a null result means that the record has not been published.
[中]获取注册id（如果有）。获取空结果意味着记录尚未发布。

代码示例

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

discovery.unpublish(record1.getRegistration(), ar -> {
 if (ar.succeeded()) {
  System.out.println("\"" + record1.getName() + "\" successfully unpublished");

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

@Override
public void remove(Record record, Handler<AsyncResult<Record>> resultHandler) {
 Objects.requireNonNull(record.getRegistration(), "No registration id in the record");
 remove(record.getRegistration(), resultHandler);
}

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

@Override
public void remove(Record record, Handler<AsyncResult<Record>> resultHandler) {
 Objects.requireNonNull(record.getRegistration(), MESSAGE_NO_REG_ID);
 remove(record.getRegistration(), resultHandler);
}

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

@Override
public void remove(Record record, Handler<AsyncResult<Record>> resultHandler) {
 Objects.requireNonNull(record.getRegistration(), MESSAGE_NO_REG_ID);
 remove(record.getRegistration(), resultHandler);
}

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

@Override
public void remove(Record record, Handler<AsyncResult<Record>> resultHandler) {
 Objects.requireNonNull(record.getRegistration(), "No registration id in the record");
 remove(record.getRegistration(), resultHandler);
}

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

@Override
public void update(Record record, Handler<AsyncResult<Void>> resultHandler) {
 Objects.requireNonNull(record.getRegistration(), "No registration id in the record");
 redis.hset(key, record.getRegistration(), record.toJson().encode(), ar -> {
  if (ar.succeeded()) {
   resultHandler.handle(Future.succeededFuture());
  } else {
   resultHandler.handle(Future.failedFuture(ar.cause()));
  }
 });
}

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

@Override
public void update(Record record, Handler<AsyncResult<Void>> resultHandler) {
 Objects.requireNonNull(record.getRegistration(), "No registration id in the record");
 redis.hset(key, record.getRegistration(), record.toJson().encode(), ar -> {
  if (ar.succeeded()) {
   resultHandler.handle(Future.succeededFuture());
  } else {
   resultHandler.handle(Future.failedFuture(ar.cause()));
  }
 });
}

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

private void successFinished(final Record record) {
  // Build key
  final String key = this.getID(record);
  final String id = record.getRegistration();
  this.successLog(record);
  // Fill container
  REGISTRITIONS.put(key, record);
  ID_MAP.put(key, id);
}

代码示例来源：origin: sczyh30/vertx-blueprint-microservice

@Override
 public void stop(Future<Void> future) throws Exception {
  // TODO: to optimize.
  Observable.from(registeredRecords)
   .flatMap(record -> discovery.rxUnpublish(record.getRegistration()).toObservable())
   .reduce((Void) null, (a, b) -> null)
   .subscribe(future::complete, future::fail);
 }
}

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

@Override
public void remove(Record record, Handler<AsyncResult<Record>> resultHandler) {
 Objects.requireNonNull(record.getRegistration(), "No registration id in the record");
 Future<Void> deregistration = Future.future();
 client.deregisterService(record.getRegistration(), deregistration);
 deregistration.map(record).setHandler(resultHandler);
}

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

@Override
public void store(Record record, Handler<AsyncResult<Record>> resultHandler) {
 String uuid = UUID.randomUUID().toString();
 if (record.getRegistration() != null) {
  throw new IllegalArgumentException("The record has already been registered");
 }
 ServiceOptions serviceOptions = recordToServiceOptions(record, uuid);
 record.setRegistration(serviceOptions.getId());
 Future<Void> registration = Future.future();
 client.registerService(serviceOptions, registration);
 registration.map(record).setHandler(resultHandler);
}

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

private void successLog(final Record record) {
  final String key = this.getID(record);
  final String id = record.getRegistration();
  final String endpoint = MessageFormat.format("http://{0}:{1}{2}",
      record.getLocation().getString(Origin.HOST),
      String.valueOf(record.getLocation().getInteger(Origin.PORT)),
      record.getMetadata().getString(Origin.PATH));
  LOGGER.debug(Info.REG_SUCCESS, record.getStatus(),
      record.getType(), record.getName(),
      endpoint, key, id);
}

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

private void unpublish(DockerService service) {
 for (Record record : service.records()) {
  publisher.unpublish(record.getRegistration(), ar -> {
   LOGGER.info("Service from container " + service.id()
     + " on location " + record.getLocation() + " has been unpublished");
  });
 }
}

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

@Test
public void testPublicationWithoutStatus() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost");
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.UP);
}

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

@Test
public void testPublicationWithoutStatus() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost");
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.UP);
}

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

@Test
public void testPublicationWithStatusOutOfService() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.OUT_OF_SERVICE);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.OUT_OF_SERVICE);
}

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

@Test
public void testPublicationWithStatusUnknown() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.UNKNOWN);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.UP);
}

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

@Test
public void testPublicationWithStatusDown() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.DOWN);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.DOWN);
}

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

@Test
public void testPublicationWithStatusUp() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.UP);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.UP);
}

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

@Test
public void testPublicationWithStatusDown() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.DOWN);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.DOWN);
}

内容来源于网络，如有侵权，请联系作者删除！

record

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com