由于业务需要,在一个handler类里面增加了线程池的处理。
最终导致了BaseRepository.save方法的异常。
public class BaseRepository<T, ID> extends AbstractElasticsearchRepository
public <S extends T> S save(S entitie, EsIndex esIndex, String suffixDateField, EsType esType) {
if (null == esIndex)
return null;
String indexName = buildIndexName(esIndex.getName(), suffixDateField, entitie);
IndexQuery indexQuery = createIndexQuery(entitie, indexName, esType.getType());
template.index(indexQuery);
refresh(indexName);
return entitie;
}
上面是BaseRepository类save方法。
目前还木有思路。 不清楚线程池 怎么就影响了ElasticsearchTemplate。 希望一些大神能提供下思路。
最终导致了BaseRepository.save方法的异常。
public class BaseRepository<T, ID> extends AbstractElasticsearchRepository
public <S extends T> S save(S entitie, EsIndex esIndex, String suffixDateField, EsType esType) {
if (null == esIndex)
return null;
String indexName = buildIndexName(esIndex.getName(), suffixDateField, entitie);
IndexQuery indexQuery = createIndexQuery(entitie, indexName, esType.getType());
template.index(indexQuery);
refresh(indexName);
return entitie;
}
上面是BaseRepository类save方法。
目前还木有思路。 不清楚线程池 怎么就影响了ElasticsearchTemplate。 希望一些大神能提供下思路。
0 个回复