org.springframework.boot.actuate.endpoint.annotation.Endpoint#org.springframework.cloud.bus.BusProperties源码实例Demo

/**
 * 自定义网关监控端点
 *
 * @param context
 * @param bus
 * @return
 */
@Bean
@ConditionalOnEnabledEndpoint
@ConditionalOnClass({Endpoint.class})
public ApiEndpoint apiEndpoint(ApplicationContext context, BusProperties bus) {
    ApiEndpoint endpoint = new ApiEndpoint(context, bus.getId());
    log.info("ApiEndpoint [{}]", endpoint);
    return endpoint;
}
 

/**
 * 网关bus端点
 *
 * @param context
 * @param bus
 * @return
 */
@Bean
@ConditionalOnEnabledEndpoint
@ConditionalOnClass({Endpoint.class})
public ApiEndpoint apiEndpoint(ApplicationContext context, BusProperties bus) {
    ApiEndpoint endpoint = new ApiEndpoint(context, bus.getId());
    log.info("ApiEndpoint [{}]", endpoint);
    return endpoint;
}
 

/**
 * 自定义Oauth2请求类
 *
 * @param openCommonProperties
 * @return
 */
@Bean
@ConditionalOnMissingBean(OpenRestTemplate.class)
public OpenRestTemplate openRestTemplate(OpenCommonProperties openCommonProperties, BusProperties busProperties, ApplicationEventPublisher publisher) {
    OpenRestTemplate restTemplate = new OpenRestTemplate(openCommonProperties, busProperties, publisher);
    //设置自定义ErrorHandler
    restTemplate.setErrorHandler(new OpenRestResponseErrorHandler());
    log.info("OpenRestTemplate [{}]", restTemplate);
    return restTemplate;
}
 

public OpenRestTemplate(OpenCommonProperties common,  BusProperties busProperties, ApplicationEventPublisher publisher) {
    this.common = common;
    this.publisher = publisher;
    this.busProperties = busProperties;
}
 

@Bean
public PropertyPathEndpoint propertyPathEndpoint(BusProperties busProperties) {
	return new PropertyPathEndpoint(
			new CompositePropertyPathNotificationExtractor(this.extractors),
			busProperties.getId());
}
 

@Bean
public BusProperties busProperties() {
	return new BusProperties();
}