Package com.norconex.committer.core.service

Class CommitterService<T>

java.lang.Object

com.norconex.committer.core.service.CommitterService<T>

Type Parameters:

T - type of committed objects

All Implemented Interfaces:

Closeable, AutoCloseable

public class CommitterService<T>
extends Object
implements Closeable

Wrapper around multiple Committers so they can all be handled as one and facilitating integration with various clients.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CommitterService.CommitterServiceBuilder<T>

Method Summary

Modifier and Type	Method	Description
static <T> CommitterService.CommitterServiceBuilder<T>	builder()
protected boolean	canEqual(Object other)
void	clean()	Cleans all registered committers.
void	close()	Closes all registered committers.
List<Committer>	delete(T object)	Deletes an object using all accepting committers.
boolean	equals(Object o)
List<Committer>	getCommitters()
@NonNull Function<T,DeleteRequest>	getDeleteRequestBuilder()
EventManager	getEventManager()
@NonNull Function<T,UpsertRequest>	getUpsertRequestBuilder()
int	hashCode()
void	init(CommitterContext baseContext)
boolean	isOperative()
String	toString()
List<Committer>	upsert(T object)	Updates or inserts an object using all accepting committers.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Details

isOperative

public boolean isOperative()

init

public void init(CommitterContext baseContext)
          throws CommitterServiceException

Throws:

CommitterServiceException

upsert

public List<Committer> upsert(T object)
                       throws CommitterServiceException

Updates or inserts an object using all accepting committers.

Parameters:

object - the object to upsert

Returns:

committers having accepted and upserted the object

Throws:

CommitterServiceException - wrapper around operation failure one or more of the registered committers (wraps last exception captured)

delete

public List<Committer> delete(T object)
                       throws CommitterServiceException

Deletes an object using all accepting committers.

Parameters:

object - the object to delete

Returns:

committers having accepted and deleted the object

Throws:

CommitterServiceException - wrapper around operation failure one or more of the registered committers (wraps last exception captured)

close

public void close()
           throws CommitterServiceException

Closes all registered committers.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

CommitterServiceException - wrapper around operation failure one or more of the registered committers (wraps last exception captured)

clean

public void clean()
           throws CommitterServiceException

Cleans all registered committers.

Throws:

CommitterServiceException - wrapper around operation failure one or more of the registered committers (wraps last exception captured)

toString

public String toString()

Overrides:

toString in class Object

builder

public static <T>
CommitterService.CommitterServiceBuilder<T> builder()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

canEqual

protected boolean canEqual(Object other)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getCommitters

public List<Committer> getCommitters()

getEventManager

public EventManager getEventManager()

getUpsertRequestBuilder

@NonNull
public @NonNull Function<T,UpsertRequest> getUpsertRequestBuilder()

getDeleteRequestBuilder

@NonNull
public @NonNull Function<T,DeleteRequest> getDeleteRequestBuilder()