All Classes and Interfaces

Class
Description
 
 
Keeps track of offset and processed status and manages coordinates the import/retry handling.
 
 
 
 
 
 
Default implementation of a DistributionLog
Log level
 
 
 
Listens for discovery messages and tracks presence of Subscribers as well as the last processed offset of each Subscriber This component is only activated when there is at least one DistributionSubscriber agent configured.
 
 
 
Listens to log message events (for errors) and package distributed events (for success) and logs both to the given DefaultDistributionLog
A Publisher SCD agent which produces messages to be consumed by a DistributionSubscriber agent.
A Subscriber SCD agent which consumes messages produced by a DistributionPublisher agent.
 
Retry with exponential backoff.
 
 
 
 
 
 
 
 
A no-operation (no-op) implementation of the ImportPreProcessor interface.
 
A queue of T items indexed by offsets.
 
 
 
 
 
Holds package retries by agent name
 
Extension point for checking if a package can be processed by a subscriber.
 
 
 
This service checks for DistributionPublisher agent configuration availability and registers the marker service PublisherConfigurationAvailable when such configuration could be found.
 
 
 
Normally PubQueueProvider should be created per publish agent.
 
 
 
 
 
 
This is a precondition that watches status messages from other instances in order to confirm that a package can be processed.
 
 
 
 
Metrics for DistributionSubscriber most metrics will have two parameters: TAG_SUB_NAME and TAG_EDITABLE
A DistributionSubscriber is considered ready when one of the conditions is met: is idle (no further message received) for more than the idleMillis at least once is busy processing the same package for more than MAX_RETRIES times.