Event Outbox Processor Service
Description
This service is responsible for handling the continuous
forwarding of event messages in the outbox repository to a message broker.
May be used by
Properties
Outbox Repository (
outboxRepository) Description
Settings for the event outbox repository.
Attributes
Plugin-Link
Mandatory
Assignable plugins
Message Broker Selectors (
messageBrokerSelectors) Description
List of message broker selectors. The message is sent using the message broker configured in the first selector that matches. If none of the selectors match, the message is deleted from the outbox without being sent to any message broker.
Attributes
Plugin-List
Mandatory
Assignable plugins
Batch Size (
batchSize) Description
Number of events to be processed during each run. A batch cycle includes reading from the repository (DB), forwarding the messages and cleanup.
Attributes
Integer
Optional
Default value
1000
Min. Interval [ms] (
minIntervalMillis) Description
Minimum interval in milliseconds to wait before sending the next batch of messages. If the sending takes longer than this interval, the next batch is sent immediately after sending is finished. Otherwise, the process waits for the remaining time of the interval to continue. If sending of all messages in a batch failed, the waiting interval is doubled until "Max Interval [ms]" is reached. Once at least one message could be sent successfully, the waiting interval is reset to this minimum.
Attributes
Integer
Optional
Default value
500
Max. Interval [ms] (
maxIntervalMillis) Description
Maximum interval in milliseconds to wait before sending the next batch of messages. If sending of all messages in a batch failed, the waiting interval is doubled until this maximum is reached. Once at least one message could be sent successfully, the waiting interval is reset to "Min. Interval [ms]".
This interval cannot be upheld if sending the messages takes longer than this interval (for example, due to timeouts or network issues).
This interval cannot be upheld if sending the messages takes longer than this interval (for example, due to timeouts or network issues).
Attributes
Integer
Optional
Default value
10000
YAML Template (with default values)
type: EventOutboxProcessorService
id: EventOutboxProcessorService-xxxxxx
displayName:
comment:
properties:
batchSize: 1000
maxIntervalMillis: 10000
messageBrokerSelectors:
minIntervalMillis: 500
outboxRepository: