consumers

type Delivery struct {
	ContentType     string // MIME content type
	ContentEncoding string // MIME content encoding
	Body            []byte
	MessageId       string    // application use - message identifier
	Timestamp       time.Time // application use - message timestamp
	Type            string    // application use - message type name
}

type HandleFunc func(<-chan amqp.Delivery, log.Logger)

type IConsumer interface {
	Consume(handleFunc HandleFunc, logger log.Logger) error
	Close() error
}