primaryqueue

Documentation

Index

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

Constants

const ConsumerTimeout = 45 * time.Second // reserve 15 sec

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

Functions

func RegisterConsumer

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