Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DelayedRetryStrategyPreset ¶
type DelayedRetryStrategyPreset struct { // Queue - main queue declare params, is required Queue *rmq.DeclareParams // DelayQueue - queue for storing messages, which will be sent to main q after expiration, not required DelayQueue *rmq.DeclareParams // FailedQueue - queue for storing messages, which has an error at handling after n retries FailedQueue *rmq.DeclareParams // ExchangeName - name of core exchange, which will has binds to all 3 queues ExchangeName string // RoutingKeys - main rk for bind, binds to delay and failed queues will be generated from this value RoutingKeys RoutingKeys }
DelayedRetryStrategyPreset - creates a queue set for delayed msg handling retry
type RoutingKeys ¶ added in v0.3.4
DelayedRetryStrategyPreset - creates a queue set for delayed msg handling retry
Click to show internal directories.
Click to hide internal directories.