All Classes and Interfaces
Class
Description
Keeps track of offset and processed status and manages
coordinates the import/retry handling.
Default implementation of a
DistributionLogLog 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.