presets

package
v0.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 15, 2022 License: Unlicense Imports: 5 Imported by: 0

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

func (*DelayedRetryStrategyPreset) Apply

func (drsp *DelayedRetryStrategyPreset) Apply(_ *amqp.Channel, schema *rmq.Schema) (err error)

Apply - applies preset

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL