2020-09-04 14:33:19 +02:00
|
|
|
package eu.dnetlib.broker;
|
2020-08-28 09:40:04 +02:00
|
|
|
|
|
|
|
import org.elasticsearch.client.RestHighLevelClient;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
2021-07-30 16:17:20 +02:00
|
|
|
import org.springframework.cache.annotation.EnableCaching;
|
2020-08-28 09:40:04 +02:00
|
|
|
import org.springframework.context.annotation.Bean;
|
2021-11-29 13:37:27 +01:00
|
|
|
import org.springframework.context.annotation.ComponentScan;
|
2020-08-28 09:40:04 +02:00
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
|
import org.springframework.data.elasticsearch.client.ClientConfiguration;
|
|
|
|
import org.springframework.data.elasticsearch.client.RestClients;
|
|
|
|
import org.springframework.data.elasticsearch.config.AbstractElasticsearchConfiguration;
|
|
|
|
import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;
|
|
|
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
|
|
|
import org.springframework.transaction.annotation.EnableTransactionManagement;
|
|
|
|
|
2020-09-04 14:33:19 +02:00
|
|
|
import eu.dnetlib.broker.common.elasticsearch.Event;
|
|
|
|
import eu.dnetlib.broker.common.elasticsearch.Notification;
|
|
|
|
import eu.dnetlib.broker.common.properties.ElasticSearchProperties;
|
2020-08-28 09:40:04 +02:00
|
|
|
|
|
|
|
@Configuration
|
2021-07-30 16:17:20 +02:00
|
|
|
@EnableCaching
|
2020-08-28 09:40:04 +02:00
|
|
|
@EnableScheduling
|
|
|
|
@EnableTransactionManagement
|
|
|
|
@EnableElasticsearchRepositories(basePackageClasses = {
|
|
|
|
Event.class, Notification.class
|
|
|
|
})
|
2021-11-29 13:37:27 +01:00
|
|
|
@ComponentScan(basePackages = "eu.dnetlib")
|
2020-08-28 09:40:04 +02:00
|
|
|
public class BrokerConfiguration extends AbstractElasticsearchConfiguration {
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
private ElasticSearchProperties elasticSearchProperties;
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Bean
|
|
|
|
public RestHighLevelClient elasticsearchClient() {
|
|
|
|
final ClientConfiguration clientConfiguration = ClientConfiguration.builder()
|
2020-11-18 09:53:02 +01:00
|
|
|
.connectedTo(elasticSearchProperties.getClusterNodes().split(","))
|
2020-08-28 09:40:04 +02:00
|
|
|
.withConnectTimeout(elasticSearchProperties.getConnectionTimeout())
|
|
|
|
.withSocketTimeout(elasticSearchProperties.getSocketTimeout())
|
|
|
|
.build();
|
|
|
|
return RestClients.create(clientConfiguration).rest();
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|