- All Implemented Interfaces:
- Runnable
@ParametersAreNonnullByDefault
public class PackageCleanupTask
extends Object
implements Runnable
The cleanup task fetches the head offset (the smallest) and
the tail offset (the current biggest) on the package topic.
The stored packages are then scanned and cleaned if they are
no longer referenced by the package topic (offset smaller than
the head offset).
With clustered deployment, only one Publisher agent should run
the package cleanup task on the cluster