gcppubsub

Dec 18, 2018

Changes in this version

+ func New(cnf *config.Config, projectID, subscriptionName string) (iface.Broker, error)

+ type Broker struct

+ 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()