@Autowired
public EsRestClient(JkesSearchProperties jkesProperties) {
SniffOnFailureListener sniffOnFailureListener = new SniffOnFailureListener();
Header[] defaultHeaders = {new BasicHeader("Content-Type", "application/json")};
String[] urls = jkesProperties.getEs().getServers().split("\\s*,");
HttpHost[] hosts = new HttpHost[urls.length];
for (int i = 0; i < urls.length; i++) {
hosts[i] = HttpHost.create(urls[i]);
}
RestClient restClient = RestClient.builder(hosts)
.setRequestConfigCallback(requestConfigBuilder -> {
return requestConfigBuilder.setConnectTimeout(5000) // default 1s
.setSocketTimeout(60000); // defaults to 30 seconds
}).setHttpClientConfigCallback(httpClientBuilder -> {
return httpClientBuilder.setDefaultIOReactorConfig(
IOReactorConfig.custom().setIoThreadCount(2).build()); // because only used for admin, so not necessary to hold many worker threads
})
.setMaxRetryTimeoutMillis(60000) // defaults to 30 seconds
.setDefaultHeaders(defaultHeaders)
.setFailureListener(sniffOnFailureListener)
.build();
Sniffer sniffer = Sniffer.builder(restClient).build();
sniffOnFailureListener.setSniffer(sniffer);
this.sniffer = sniffer;
this.restClient = restClient;
}
java类org.springframework.beans.factory.annotation.Autowired的实例源码
EsRestClient.java 文件源码
项目:jkes
阅读 22
收藏 0
点赞 0
评论 0
CalendarUserDetailsService.java 文件源码
项目:Spring-Security-Third-Edition
阅读 21
收藏 0
点赞 0
评论 0
@Autowired
public CalendarUserDetailsService(CalendarUserDao calendarUserDao) {
if (calendarUserDao == null) {
throw new IllegalArgumentException("calendarUserDao cannot be null");
}
this.calendarUserDao = calendarUserDao;
}
MetricsConfiguration.java 文件源码
项目:Armory
阅读 24
收藏 0
点赞 0
评论 0
@Autowired(required = false)
public void setHikariDataSource(HikariDataSource hikariDataSource) {
this.hikariDataSource = hikariDataSource;
}
EndFileController.java 文件源码
项目:recruitervision
阅读 22
收藏 0
点赞 0
评论 0
@Autowired
public EndFileController(ScreensManager screensManager, PDFCreator pdfCreator, JSONCreator jsonCreator) {
this.screensManager = screensManager;
this.pdfCreator = pdfCreator;
this.jsonCreator = jsonCreator;
}
IdServerConfiguration.java 文件源码
项目:jigsaw-payment
阅读 23
收藏 0
点赞 0
评论 0
@Bean
@Autowired
public RedisTemplate redisTemplate(ShardedJedisPool shardedJedisPool){
return new RedisTemplate(shardedJedisPool);
}
ReportForms.java 文件源码
项目:ARCLib
阅读 24
收藏 0
点赞 0
评论 0
@Autowired(required = false)
public void setForms(List<ReportForm> forms) {
this.forms = forms != null ? forms : emptyList();
}
SettingService.java 文件源码
项目:sentry
阅读 22
收藏 0
点赞 0
评论 0
@Autowired
public SettingService(SettingRepository settingRepository, SettingMapper settingMapper,
SentryProperties sentryProperties) {
this.settingRepository = settingRepository;
this.settingMapper = settingMapper;
this.sentryProperties = sentryProperties;
}
I18nUtil.java 文件源码
项目:mafia
阅读 24
收藏 0
点赞 0
评论 0
@Autowired
public void setMessageSource(MessageSource messageSource) {
I18nUtil.messageSource = messageSource;
}
AuthApiController.java 文件源码
项目:yum
阅读 28
收藏 0
点赞 0
评论 0
@Autowired
public AuthApiController(AuthService authService) {
this.authService = authService;
}
NotificationService.java 文件源码
项目:ARCLib
阅读 27
收藏 0
点赞 0
评论 0
@Autowired(required = false)
public void setUserDetails(UserDetails userDetails) {
this.userDetails = userDetails;
}