queue

Documentation

Index

• type AmqpConsumer
  • func NewAmqpConsumer(conf *config.Config, taskService service.TaskService) *AmqpConsumer
  • func (al *AmqpConsumer) ReadFromQueue()
• type Consumer

Types

type AmqpConsumer

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

func NewAmqpConsumer

func NewAmqpConsumer(conf *config.Config, taskService service.TaskService) *AmqpConsumer

func (*AmqpConsumer) ReadFromQueue

func (al *AmqpConsumer) ReadFromQueue()

type Consumer

type Consumer interface {
	ReadFromQueue()
}