fix
This commit is contained in:
parent
f2bd42005a
commit
5928f23176
@ -187,8 +187,8 @@ public class FileElasticsearchGateway {
|
|||||||
String docId = docModel.buildDocId();
|
String docId = docModel.buildDocId();
|
||||||
Map<String, Object> source = BeanUtil.beanToMap(docModel, false, true);
|
Map<String, Object> source = BeanUtil.beanToMap(docModel, false, true);
|
||||||
IndexRequest request = new IndexRequest(INDEX_NAME).id(docId).source(source);
|
IndexRequest request = new IndexRequest(INDEX_NAME).id(docId).source(source);
|
||||||
IndexResponse response = esClient.index(request, RequestOptions.DEFAULT);
|
esClient.index(request, RequestOptions.DEFAULT);
|
||||||
return response.status().getStatus() == RestStatus.OK.getStatus();
|
return true;
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error("ES 写入文档失败: doc={}", docModel, e);
|
log.error("ES 写入文档失败: doc={}", docModel, e);
|
||||||
return false;
|
return false;
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user