org.apache.sling.distribution.journal.impl.subscriber

Class StagingPrecondition

java.lang.Object

org.apache.sling.distribution.journal.impl.subscriber.StagingPrecondition

All Implemented Interfaces:

Precondition

public class StagingPrecondition
extends Object
implements Precondition

This is a precondition that watches status messages from other instances in order to confirm that a package can be processed. The check will block until a status is found. If no status is received in 60 seconds it will throw an exception.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	StagingPrecondition.Configuration

Constructor Summary

Constructors

Constructor and Description
StagingPrecondition()

Method Summary

Modifier and Type	Method and Description
void	activate(StagingPrecondition.Configuration config)
boolean	canProcess(long pkgOffset, int timeoutSeconds) Checks if a package can be processed
void	deactivate()

Methods inherited from class java.lang.Object

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

Constructor Detail

StagingPrecondition

public StagingPrecondition()

Method Detail

activate

public void activate(StagingPrecondition.Configuration config)

deactivate

public void deactivate()

canProcess

public boolean canProcess(long pkgOffset,
                          int timeoutSeconds)

Description copied from interface: Precondition

Checks if a package can be processed

Specified by:

canProcess in interface Precondition

Parameters:

pkgOffset - the offset of the package

timeoutSeconds - max seconds to wait until returning

Returns:

true if the package can be processed; otherwise it returns false.