presets

package
v0.3.4 Latest Latest
Warning

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

Go to latest
Published: Mar 10, 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
	// 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

func (*DelayedRetryStrategyPreset) Apply

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

Apply - applies preset

type RoutingKeys added in v0.3.4

type RoutingKeys struct {
	MainQueueRK    string
	DelayedQueueRK string
	FailedQueueRK  string
}

DelayedRetryStrategyPreset - creates a queue set for delayed msg handling retry

Jump to

Keyboard shortcuts

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