brokers

type AMQPBroker struct {
	Broker
	common.AMQPConnector
	// contains filtered or unexported fields
}

type Broker struct {
	// contains filtered or unexported fields
}

type ErrCouldNotUnmarshaTaskSignature struct {
	// contains filtered or unexported fields
}

type Interface interface {
	GetConfig() *config.Config
	SetRegisteredTaskNames(names []string)
	IsTaskRegistered(name string) bool
	StartConsuming(consumerTag string, concurrency int, p TaskProcessor) (bool, error)
	StopConsuming()
	Publish(task *tasks.Signature) error
	GetPendingTasks(queue string) ([]*tasks.Signature, error)
}

type TaskProcessor interface {
	Process(signature *tasks.Signature) error
	ProcessBatch(parent *tasks.Signature, signatures []*tasks.Signature, pool chan struct{}) error
}