Java InstanceRegisteredEvent类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent类的典型用法代码示例。如果您正苦于以下问题：Java InstanceRegisteredEvent类的具体用法？Java InstanceRegisteredEvent怎么用？Java InstanceRegisteredEvent使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

InstanceRegisteredEvent类属于org.springframework.cloud.client.discovery.event包，在下文中一共展示了InstanceRegisteredEvent类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: deleteRoute

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@RequestMapping(path = "/_remove/{routeId}", method = RequestMethod.GET,
    produces = {MediaType.TEXT_HTML_VALUE, MediaType.APPLICATION_XHTML_XML_VALUE})
public String deleteRoute(@PathVariable("routeId") String routeId,
    RedirectAttributes attributes) {

  zuulRouteRepository.findOneByRouteId(routeId).map(zuulRouteEntity -> {
    zuulRouteRepository.delete(zuulRouteEntity);
    addSuccessMessage(attributes, "路由 " + routeId + " 已删除。");
    publisher.publishEvent(new InstanceRegisteredEvent<>(this, this.environment));
    return zuulRouteEntity;
  }).orElseGet(() -> {
    addWarningMessage(attributes, "没有找到 " + routeId + " 路由。");
    return null;
  });
  return "redirect:/restRoute.html";
}

开发者ID:venus-boot，项目名称:saluki，代码行数:17，代码来源:RestRouteAdminController.java

示例2: start

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
public void start() {
	if (!isEnabled()) {
		if (logger.isDebugEnabled()) {
			logger.debug("Discovery Lifecycle disabled. Not starting");
		}
		return;
	}

	// only initialize if nonSecurePort is greater than 0 and it isn't already running
	// because of containerPortInitializer below
	if (!this.running.get()) {
		register();
		if (shouldRegisterManagement()) {
			registerManagement();
		}
		this.context.publishEvent(
				new InstanceRegisteredEvent<>(this, getConfiguration()));
		this.running.compareAndSet(false, true);
	}

}

开发者ID:spring-cloud，项目名称:spring-cloud-commons，代码行数:22，代码来源:AbstractAutoServiceRegistration.java

示例3: start

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@Override
public void start() {
	// only set the port if the nonSecurePort or securePort is 0 and this.port != 0
	if (this.port.get() != 0) {
		if (this.registration.getNonSecurePort() == 0) {
			this.registration.setNonSecurePort(this.port.get());
		}

		if (this.registration.getSecurePort() == 0 && this.registration.isSecure()) {
			this.registration.setSecurePort(this.port.get());
		}
	}

	// only initialize if nonSecurePort is greater than 0 and it isn't already running
	// because of containerPortInitializer below
	if (!this.running.get() && this.registration.getNonSecurePort() > 0) {

		this.serviceRegistry.register(this.registration);

		this.context.publishEvent(
				new InstanceRegisteredEvent<>(this, this.registration.getInstanceConfig()));
		this.running.set(true);
	}
}

开发者ID:spring-cloud，项目名称:spring-cloud-netflix，代码行数:25，代码来源:EurekaAutoServiceRegistration.java

示例4: test_matching_and_ignore_pattern

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@Test
public void test_matching_and_ignore_pattern() {
    when(discovery.getServices()).thenReturn(asList("service-1", "service", "rabbit-1", "rabbit-2"));
    when(discovery.getInstances("service")).thenReturn(
            singletonList(new DefaultServiceInstance("service", "localhost", 80, false)));
    when(discovery.getInstances("service-1")).thenReturn(
            singletonList(new DefaultServiceInstance("service-1", "localhost", 80, false)));

    listener.setServices(singleton("ser*"));
    listener.setIgnoredServices(singleton("service-*"));
    listener.onInstanceRegistered(new InstanceRegisteredEvent<>(new Object(), null));

    StepVerifier.create(registry.getInstances())
                .assertNext(a -> assertThat(a.getRegistration().getName()).isEqualTo("service"))
                .verifyComplete();
}

开发者ID:codecentric，项目名称:spring-boot-admin，代码行数:17，代码来源:InstanceDiscoveryListenerTest.java

示例5: test_register_and_convert

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@Test
public void test_register_and_convert() {
    when(discovery.getServices()).thenReturn(singletonList("service"));
    when(discovery.getInstances("service")).thenReturn(
            singletonList(new DefaultServiceInstance("service", "localhost", 80, false)));

    listener.onInstanceRegistered(new InstanceRegisteredEvent<>(new Object(), null));

    StepVerifier.create(registry.getInstances()).assertNext(application -> {
        Registration registration = application.getRegistration();
        assertThat(registration.getHealthUrl()).isEqualTo("http://localhost:80/health");
        assertThat(registration.getManagementUrl()).isEqualTo("http://localhost:80/");
        assertThat(registration.getServiceUrl()).isEqualTo("http://localhost:80/");
        assertThat(registration.getName()).isEqualTo("service");
    }).verifyComplete();


}

开发者ID:codecentric，项目名称:spring-boot-admin，代码行数:19，代码来源:InstanceDiscoveryListenerTest.java

示例6: registerInstance

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@Override
protected URI registerInstance() {
    //We register the instance by setting static values for the SimpleDiscoveryClient and issuing a
    //InstanceRegisteredEvent that makes sure the instance gets registered.
    SimpleDiscoveryProperties.SimpleServiceInstance serviceInstance = new SimpleDiscoveryProperties.SimpleServiceInstance();
    serviceInstance.setServiceId("Test-Instance");
    serviceInstance.setUri(URI.create("http://localhost:" + getPort()));
    serviceInstance.getMetadata().put("management.context-path", "/mgmt");
    simpleDiscovery.getInstances().put("Test-Application", singletonList(serviceInstance));

    instance.publishEvent(new InstanceRegisteredEvent<>(new Object(), null));

    //To get the location of the registered instances we fetch the instance with the name.
    List<JSONObject> applications = getWebClient().get()
                                                  .uri("/instances?name=Test-Instance")
                                                  .accept(MediaType.APPLICATION_JSON)
                                                  .exchange()
                                                  .expectStatus()
                                                  .isOk()
                                                  .returnResult(JSONObject.class)
                                                  .getResponseBody()
                                                  .collectList()
                                                  .block();
    assertThat(applications).hasSize(1);
    return URI.create("http://localhost:" + getPort() + "/instances/" + applications.get(0).optString("id"));
}

开发者ID:codecentric，项目名称:spring-boot-admin，代码行数:27，代码来源:AdminApplicationDiscoveryTest.java

示例7: deleteRoute

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@RequestMapping(path = "/_remove/{routeId}", method = RequestMethod.GET, produces = { MediaType.TEXT_HTML_VALUE,
                                                                                      MediaType.APPLICATION_XHTML_XML_VALUE })
public String deleteRoute(@PathVariable("routeId") String routeId, RedirectAttributes attributes) {

    zuulRouteRepository.findOneByRouteId(routeId).map(zuulRouteEntity -> {
        zuulRouteRepository.delete(zuulRouteEntity);
        addSuccessMessage(attributes, "路由 " + routeId + " 已删除。");
        publisher.publishEvent(new InstanceRegisteredEvent<>(this, this.environment));
        return zuulRouteEntity;
    }).orElseGet(() -> {
        addWarningMessage(attributes, "没有找到 " + routeId + " 路由。");
        return null;
    });
    return "redirect:/grpcRoute.html";
}

开发者ID:venus-boot，项目名称:saluki，代码行数:16，代码来源:GrpcRouteAdminController.java

示例8: create

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@RequestMapping(path = "/_create", method = RequestMethod.POST,
    consumes = MediaType.APPLICATION_FORM_URLENCODED_VALUE,
    produces = {MediaType.TEXT_HTML_VALUE, MediaType.APPLICATION_XHTML_XML_VALUE})
public String create(@RequestParam(name = "routeId", required = true) String routeId,
    @RequestParam(name = "routePath", required = true) String routePath,
    @RequestParam(name = "routeUrl", required = true) String routeUrl,
    @RequestParam(name = "serviceId", required = true) String serviceId,
    @RequestParam(name = "stripPrefix", defaultValue = "false") Boolean stripPrefix,
    @RequestParam(name = "retryAble", defaultValue = "false") Boolean retryAble,
    @RequestParam(name = "sensitiveHeaders", defaultValue = "") String sensitiveHeaders,
    RedirectAttributes attributes) {
  if (zuulRouteRepository.findOneByRouteId(routeId).isPresent()) {
    addErrorMessage(attributes, routeId + "已经存在 ");
    resetRequestParams(routeId, routePath, routeUrl, serviceId, stripPrefix, retryAble,
        sensitiveHeaders, attributes);
    return "redirect:/restRoute.html?type=add";
  }
  ZuulRouteEntity entityRest = ZuulRouteEntity.builder()//
      .zuul_route_id(routeId)//
      .path(routePath)//
      .strip_prefix(stripPrefix)//
      .retryable(retryAble)//
      .url(routeUrl)//
      .service_id(serviceId)//
      .sensitiveHeaders(sensitiveHeaders)//
      .build();
  zuulRouteRepository.save(entityRest);
  publisher.publishEvent(new InstanceRegisteredEvent<>(this, this.environment));
  return "redirect:/restRoute.html";
}

开发者ID:venus-boot，项目名称:saluki，代码行数:31，代码来源:RestRouteAdminController.java

示例9: update

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@RequestMapping(path = "/_update", method = RequestMethod.POST,
    consumes = MediaType.APPLICATION_FORM_URLENCODED_VALUE,
    produces = {MediaType.TEXT_HTML_VALUE, MediaType.APPLICATION_XHTML_XML_VALUE})
public String update(@RequestParam(name = "routeId", required = true) String routeId,
    @RequestParam(name = "routePath", required = true) String routePath,
    @RequestParam(name = "routeUrl", required = true) String routeUrl,
    @RequestParam(name = "serviceId", required = true) String serviceId,
    @RequestParam(name = "stripPrefix", defaultValue = "false") Boolean stripPrefix,
    @RequestParam(name = "retryAble", defaultValue = "false") Boolean retryAble,
    @RequestParam(name = "sensitiveHeaders", defaultValue = "") String sensitiveHeaders,
    RedirectAttributes attributes) {

  zuulRouteRepository.findOneByRouteId(routeId).map(zuulRouteEntity -> {
    zuulRouteEntity.setZuul_route_id(routeId);
    zuulRouteEntity.setPath(routePath);
    zuulRouteEntity.setUrl(routeUrl);
    zuulRouteEntity.setService_id(serviceId);
    zuulRouteEntity.setStrip_prefix(stripPrefix);
    zuulRouteEntity.setRetryable(retryAble);
    zuulRouteEntity.setSensitiveHeaders(sensitiveHeaders);
    return zuulRouteRepository.save(zuulRouteEntity);
  }).orElseGet(() -> {
    addErrorMessage(attributes, "routeId" + routeId + " 不存在。");
    return null;
  });
  publisher.publishEvent(new InstanceRegisteredEvent<>(this, this.environment));
  return "redirect:/restRoute.html";
}

开发者ID:venus-boot，项目名称:saluki，代码行数:29，代码来源:RestRouteAdminController.java

示例10: save

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@RequestMapping(value = "/", method = RequestMethod.POST)
public void save(@RequestBody Document document) throws Exception {
    Swagger swagger = new SwaggerParser()
            .read(document.getUrl());
    String content = objectMapper.writeValueAsString(swagger);
    if(StringUtils.isBlank(document.getTitle())){
        document.setTitle(swagger.getInfo().getTitle());
    }
    documentService.save(document.setContent(content));
    applicationEventPublisher.publishEvent(new InstanceRegisteredEvent<>(SwaggerDocDiscovery.class, swagger));
}

开发者ID:wu191287278，项目名称:sc-generator，代码行数:12，代码来源:DocumentController.java

示例11: upload

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@RequestMapping(value = "/upload", method = RequestMethod.POST)
public void upload(MultipartFile file, HttpServletResponse response) throws Exception {
    ByteArrayOutputStream out = new ByteArrayOutputStream();
    IOUtils.copy(file.getInputStream(), out);
    Swagger swagger = new SwaggerParser()
            .parse(out.toString("utf-8"));
    out.close();
    String content = objectMapper.writeValueAsString(swagger);
    documentService.save(new Document()
            .setContent(content)
            .setTitle(file.getOriginalFilename()));
    applicationEventPublisher.publishEvent(new InstanceRegisteredEvent<>(SwaggerDocDiscovery.class, swagger));
    response.sendRedirect("/#/document.html");
}

开发者ID:wu191287278，项目名称:sc-generator，代码行数:15，代码来源:DocumentController.java

示例12: start

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@Override
public void start() {
    if (!isEnabled()) {
        return;
    }
    if (running.compareAndSet(false, true)) {
        register();
        getContext().publishEvent(new InstanceRegisteredEvent<>(this,
                getConfiguration()));
    }
}

开发者ID:fabric8io，项目名称:spring-cloud-kubernetes，代码行数:12，代码来源:KubernetesDiscoveryLifecycle.java

示例13: onApplicationEvent

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@Override
public void onApplicationEvent(InstanceRegisteredEvent<?> event) {
	this.cache = TreeCache.newBuilder(this.curator, this.properties.getRoot()).build();
	this.cache.getListenable().addListener(this);
	try {
		this.cache.start();
	}
	catch (Exception e) {
		ReflectionUtils.rethrowRuntimeException(e);
	}
}

开发者ID:spring-cloud，项目名称:spring-cloud-zookeeper，代码行数:12，代码来源:ZookeeperServiceWatch.java

示例14: testHealthIndicatorDescriptionDisabled

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@Test
public void testHealthIndicatorDescriptionDisabled() {
	assertNotNull("healthIndicator was null", this.healthIndicator);
	Health health = this.healthIndicator.health();
	assertHealth(health, Status.UNKNOWN);

	clientHealthIndicator.onApplicationEvent(new InstanceRegisteredEvent<>(this, null));

	health = this.healthIndicator.health();
	Status status = assertHealth(health, Status.UP);
	assertEquals("status description was wrong", "TestDiscoveryClient",
			status.getDescription());
}

开发者ID:spring-cloud，项目名称:spring-cloud-commons，代码行数:14，代码来源:DiscoveryClientHealthIndicatorTests.java

示例15: testHealthIndicator

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@Test
public void testHealthIndicator() {
	assertNotNull("healthIndicator was null", this.healthIndicator);
	Health health = this.healthIndicator.health();
	assertHealth(health, Status.UNKNOWN);

	clientHealthIndicator.onApplicationEvent(new InstanceRegisteredEvent<>(this, null));

	health = this.healthIndicator.health();
	Status status = assertHealth(health, Status.UP);
	assertEquals("status description was wrong", "",
			status.getDescription());
}

开发者ID:spring-cloud，项目名称:spring-cloud-commons，代码行数:14，代码来源:DiscoveryCompositeHealthIndicatorTests.java

示例16: test_ignore

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@Test
public void test_ignore() {
    when(discovery.getServices()).thenReturn(singletonList("service"));
    when(discovery.getInstances("service")).thenReturn(
            singletonList(new DefaultServiceInstance("service", "localhost", 80, false)));

    listener.setIgnoredServices(singleton("service"));
    listener.onInstanceRegistered(new InstanceRegisteredEvent<>(new Object(), null));

    StepVerifier.create(registry.getInstances()).verifyComplete();
}

开发者ID:codecentric，项目名称:spring-boot-admin，代码行数:12，代码来源:InstanceDiscoveryListenerTest.java

示例17: test_matching

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@Test
public void test_matching() {
    when(discovery.getServices()).thenReturn(singletonList("service"));
    when(discovery.getInstances("service")).thenReturn(
            singletonList(new DefaultServiceInstance("service", "localhost", 80, false)));

    listener.setServices(singleton("notService"));
    listener.onInstanceRegistered(new InstanceRegisteredEvent<>(new Object(), null));

    StepVerifier.create(registry.getInstances()).verifyComplete();
}

开发者ID:codecentric，项目名称:spring-boot-admin，代码行数:12，代码来源:InstanceDiscoveryListenerTest.java

示例18: test_ignore_pattern

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@Test
public void test_ignore_pattern() {
    when(discovery.getServices()).thenReturn(asList("service", "rabbit-1", "rabbit-2"));
    when(discovery.getInstances("service")).thenReturn(
            singletonList(new DefaultServiceInstance("service", "localhost", 80, false)));

    listener.setIgnoredServices(singleton("rabbit-*"));
    listener.onInstanceRegistered(new InstanceRegisteredEvent<>(new Object(), null));

    StepVerifier.create(registry.getInstances())
                .assertNext(a -> assertThat(a.getRegistration().getName()).isEqualTo("service"))
                .verifyComplete();
}

开发者ID:codecentric，项目名称:spring-boot-admin，代码行数:14，代码来源:InstanceDiscoveryListenerTest.java

示例19: test_matching_pattern

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@Test
public void test_matching_pattern() {
    when(discovery.getServices()).thenReturn(asList("service", "rabbit-1", "rabbit-2"));
    when(discovery.getInstances("service")).thenReturn(
            singletonList(new DefaultServiceInstance("service", "localhost", 80, false)));

    listener.setServices(singleton("ser*"));
    listener.onInstanceRegistered(new InstanceRegisteredEvent<>(new Object(), null));

    StepVerifier.create(registry.getInstances())
                .assertNext(a -> assertThat(a.getRegistration().getName()).isEqualTo("service"))
                .verifyComplete();
}

开发者ID:codecentric，项目名称:spring-boot-admin，代码行数:14，代码来源:InstanceDiscoveryListenerTest.java

示例20: delete

import org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent; //导入依赖的package包/类
@RequestMapping(value = "{id}", method = RequestMethod.DELETE)
public void delete(@PathVariable(value = "id") Integer id) {
    documentService.delete(id);
    applicationEventPublisher.publishEvent(new InstanceRegisteredEvent<>(SwaggerDocDiscovery.class, -1));
}

开发者ID:wu191287278，项目名称:sc-generator，代码行数:6，代码来源:DocumentController.java

注：本文中的org.springframework.cloud.client.discovery.event.InstanceRegisteredEvent类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。