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
// QueueRoutingKey - main rk for bind, binds to delay and failed queues will be generated from this value
QueueRoutingKey string
}
DelayedRetryStrategyPreset - creates a queue set for delayed msg handling retry
func NewDelayedRetryStrategyPreset ¶
func NewDelayedRetryStrategyPreset(exchangeName, rk string, queue, delayQueue, failedQueue *rmq.DeclareParams) *DelayedRetryStrategyPreset
NewDelayedRetryStrategyPreset - DelayedRetryStrategyPreset constructor
Click to show internal directories.
Click to hide internal directories.