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.