Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerCollection ¶
type ConsumerCollection struct {
Consumers []consumer.MessageConsumer
// contains filtered or unexported fields
}
ConsumerCollection controls the MessageConsumers
func New ¶
func New(c []consumer.MessageConsumer) *ConsumerCollection
New creates a ConsumerCollection.
func (*ConsumerCollection) Start ¶
func (cc *ConsumerCollection) Start(input <-chan *sqs.Message) error
Start makes all consumers start to work. They will compete for sqs.Message from the input channel.
func (*ConsumerCollection) Wait ¶
func (cc *ConsumerCollection) Wait()
Wait blocks until all consumers stop.
Source Files
Click to show internal directories.
Click to hide internal directories.