sqs

Jul 12, 2018

Changes in this version

+ func New(cnf *config.Config) iface.Broker

+ type Broker struct

+ func (b *Broker) GetPendingTasks(queue string) ([]*tasks.Signature, error)

+ func (b *Broker) Publish(signature *tasks.Signature) error

+ func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor) (bool, error)

+ func (b *Broker) StopConsuming()