consumer

Documentation

Index

• type Consumer
• type RabbitMqConsumer
  • func (c *RabbitMqConsumer) Consume()
  • func (c *RabbitMqConsumer) Initialize() error

Types

type Consumer

type Consumer interface {
	Initialize() error
	Consume()
}

type RabbitMqConsumer

type RabbitMqConsumer struct {
	Config *configuration.ConsumerConfiguration
	Merger merging.Merger
	// contains filtered or unexported fields
}

func (*RabbitMqConsumer) Consume

func (c *RabbitMqConsumer) Consume()

func (*RabbitMqConsumer) Initialize

func (c *RabbitMqConsumer) Initialize() error