rabbitmqconsumer

Documentation

Index

• type Consumer
  • func New(ctx context.Context, c dconfig.RabbitMQConsumerConnection, ...) *Consumer
  • func (c *Consumer) Close() error
  • func (c *Consumer) Consume(done <-chan bool, wg *sync.WaitGroup) (<-chan event.ProcessedEvent, error)

Types

type Consumer

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

func New

func New(ctx context.Context, c dconfig.RabbitMQConsumerConnection, topic dconfig.ConsumerTopic) *Consumer

func (*Consumer) Close

func (c *Consumer) Close() error

func (*Consumer) Consume

func (c *Consumer) Consume(done <-chan bool, wg *sync.WaitGroup) (<-chan event.ProcessedEvent, error)