Changes API: How to Subscribe to Operation Changes

Operation changes for one operation can be observed using the forOperationId method.

Syntax

IChangesObservable<OperationStatusChange> forOperationId(long operationId);

Example

CleanCloseable subscription = store
    .changes()
    .forOperationId(operationId)
    .subscribe(Observers.create(change -> {
        ObjectNode operationState = change.getState();

        // do something
    }));

Operations changes for all Operations can be observed using the forAllOperations method.

Syntax

IChangesObservable<OperationStatusChange> forAllOperations();

Example

CleanCloseable subscription = store
    .changes()
    .forAllOperations()
    .subscribe(Observers.create(change -> {
        System.out.println("Operation #" + change.getOperationId());
    }));

Properties