consumer

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

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