org.nuxeo.ecm.core.bulk

Class BulkServiceImpl

java.lang.Object

org.nuxeo.ecm.core.bulk.BulkServiceImpl

All Implemented Interfaces:

AsyncService<String,BulkStatus,Map<String,Serializable>>, BulkService

public class BulkServiceImpl
extends Object
implements BulkService

Basic implementation of BulkService.

Since:

10.2

Field Summary

Fields

Modifier and Type	Field and Description
static long	ABORTED_TTL_SECONDS
static String	BULK_KV_STORE_NAME
static String	BULK_LOG_MANAGER_NAME
static String	COMMAND_PREFIX
static String	COMMAND_STREAM
static long	COMPLETED_TTL_SECONDS
static String	DONE_STREAM
static String	PRODUCE_IMMEDIATE_OPTION
static String	RECORD_CODEC
static String	STATUS_PREFIX
static String	STATUS_STREAM

Constructor Summary

Constructors

Constructor and Description
BulkServiceImpl()

Method Summary

Modifier and Type	Method and Description
BulkStatus	abort(String commandId) Aborts an asynchronous task.
boolean	await(Duration duration) Waits for completion of all bulk commands.
boolean	await(String commandId, Duration duration) Waits for completion of given bulk command.
BulkCommand	getCommand(String commandId) Returns the command or null if the command is not found or aborted.
KeyValueStore	getKvStore()
Map<String,Serializable>	getResult(String commandId) Retrieves the command execution result.
BulkStatus	getStatus(String commandId) Returns the status of a task.
List<BulkStatus>	getStatuses(String username) Gets the list of action statuses triggered by the given user.
byte[]	setCommand(BulkCommand command) Stores the command in the kv store, returns the encoded command.
byte[]	setStatus(BulkStatus status) Stores the status in the kv store returns the encoded status
String	submit(BulkCommand command) Submits a BulkCommand that will be processed asynchronously.

Methods inherited from class java.lang.Object

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

Field Detail

BULK_LOG_MANAGER_NAME

public static final String BULK_LOG_MANAGER_NAME

See Also:

Constant Field Values

BULK_KV_STORE_NAME

public static final String BULK_KV_STORE_NAME

See Also:

Constant Field Values

COMMAND_STREAM

public static final String COMMAND_STREAM

See Also:

Constant Field Values

STATUS_STREAM

public static final String STATUS_STREAM

See Also:

Constant Field Values

DONE_STREAM

public static final String DONE_STREAM

See Also:

Constant Field Values

RECORD_CODEC

public static final String RECORD_CODEC

See Also:

Constant Field Values

COMMAND_PREFIX

public static final String COMMAND_PREFIX

See Also:

Constant Field Values

STATUS_PREFIX

public static final String STATUS_PREFIX

See Also:

Constant Field Values

PRODUCE_IMMEDIATE_OPTION

public static final String PRODUCE_IMMEDIATE_OPTION

See Also:

Constant Field Values

COMPLETED_TTL_SECONDS

public static final long COMPLETED_TTL_SECONDS

See Also:

Constant Field Values

ABORTED_TTL_SECONDS

public static final long ABORTED_TTL_SECONDS

See Also:

Constant Field Values

Constructor Detail

BulkServiceImpl

public BulkServiceImpl()

Method Detail

submit

public String submit(BulkCommand command)

Description copied from interface: BulkService

Submits a BulkCommand that will be processed asynchronously.

Specified by:

submit in interface BulkService

Parameters:

command - the command to submit

Returns:

a unique bulk command identifier

getStatus

public BulkStatus getStatus(String commandId)

Description copied from interface: AsyncService

Returns the status of a task.

Specified by:

getStatus in interface AsyncService<String,BulkStatus,Map<String,Serializable>>

setStatus

public byte[] setStatus(BulkStatus status)

Stores the status in the kv store returns the encoded status

getCommand

public BulkCommand getCommand(String commandId)

Description copied from interface: BulkService

Returns the command or null if the command is not found or aborted.

Specified by:

getCommand in interface BulkService

abort

public BulkStatus abort(String commandId)

Description copied from interface: AsyncService

Aborts an asynchronous task. Service should try to cancel the task, if not possible it must try to stop it.

Specified by:

abort in interface AsyncService<String,BulkStatus,Map<String,Serializable>>

getResult

public Map<String,Serializable> getResult(String commandId)

Description copied from interface: AsyncService

Retrieves the command execution result.

Specified by:

getResult in interface AsyncService<String,BulkStatus,Map<String,Serializable>>

setCommand

public byte[] setCommand(BulkCommand command)

Stores the command in the kv store, returns the encoded command.

await

public boolean await(String commandId,
                     Duration duration)
              throws InterruptedException

Description copied from interface: BulkService

Waits for completion of given bulk command.

Specified by:

await in interface BulkService

Parameters:

commandId - the command to wait

duration - the duration to wait

Returns:

true if bulk command completed or false if computation has not finished after the timeout

Throws:

InterruptedException

getKvStore

public KeyValueStore getKvStore()

await

public boolean await(Duration duration)
              throws InterruptedException

Description copied from interface: BulkService

Waits for completion of all bulk commands.

Specified by:

await in interface BulkService

Parameters:

duration - the duration to wait

Returns:

true if all bulk commands completed or false if one or more has not finished after the timeout

Throws:

InterruptedException

getStatuses

public List<BulkStatus> getStatuses(String username)

Description copied from interface: BulkService

Gets the list of action statuses triggered by the given user.

Specified by:

getStatuses in interface BulkService

Parameters:

username - the user name

Returns:

the list of statuses