Package org.apache.syncope.core.provisioning.java.job

Class ElasticsearchReindex.ErrorLoggingBulkListener

java.lang.Object

org.apache.syncope.core.provisioning.java.job.ElasticsearchReindex.ErrorLoggingBulkListener

All Implemented Interfaces:

co.elastic.clients.elasticsearch._helpers.bulk.BulkListener<Void>

Enclosing class:

ElasticsearchReindex

protected static class ElasticsearchReindex.ErrorLoggingBulkListener
extends Object
implements co.elastic.clients.elasticsearch._helpers.bulk.BulkListener<Void>

Field Summary

Fields

Modifier and Type	Field	Description
protected static ElasticsearchReindex.ErrorLoggingBulkListener	INSTANCE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ErrorLoggingBulkListener()

Method Summary

Modifier and Type	Method	Description
void	afterBulk(long executionId, co.elastic.clients.elasticsearch.core.BulkRequest request, List<Void> contexts, co.elastic.clients.elasticsearch.core.BulkResponse response)
void	afterBulk(long executionId, co.elastic.clients.elasticsearch.core.BulkRequest request, List<Void> contexts, Throwable failure)
void	beforeBulk(long executionId, co.elastic.clients.elasticsearch.core.BulkRequest request, List<Void> contexts)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INSTANCE

protected static final ElasticsearchReindex.ErrorLoggingBulkListener INSTANCE

Constructor Detail

ErrorLoggingBulkListener

protected ErrorLoggingBulkListener()

Method Detail

beforeBulk

public void beforeBulk(long executionId,
                       co.elastic.clients.elasticsearch.core.BulkRequest request,
                       List<Void> contexts)

Specified by:

beforeBulk in interface co.elastic.clients.elasticsearch._helpers.bulk.BulkListener<Void>

afterBulk

public void afterBulk(long executionId,
                      co.elastic.clients.elasticsearch.core.BulkRequest request,
                      List<Void> contexts,
                      co.elastic.clients.elasticsearch.core.BulkResponse response)

Specified by:

afterBulk in interface co.elastic.clients.elasticsearch._helpers.bulk.BulkListener<Void>

afterBulk

public void afterBulk(long executionId,
                      co.elastic.clients.elasticsearch.core.BulkRequest request,
                      List<Void> contexts,
                      Throwable failure)

Specified by:

afterBulk in interface co.elastic.clients.elasticsearch._helpers.bulk.BulkListener<Void>