consumer.go 145 B

12345678910
  1. package queue
  2. type (
  3. Consumer interface {
  4. Consume(string) error
  5. OnEvent(event interface{})
  6. }
  7. ConsumerFactory func() (Consumer, error)
  8. )