analyzesqueue

Documentation

Index

• Constants
• func RegisterConsumer(consumeFunc interface{}, queueID string, m *consumers.Multiplexer, ...) error

Constants

const ConsumerTimeout = 530 * time.Second // reserve 30 sec

const VisibilityTimeoutSec = 600 // must be in sync with cloudformation.yml

Functions

func RegisterConsumer

func RegisterConsumer(consumeFunc interface{}, queueID string, m *consumers.Multiplexer, df *redsync.Redsync) error