rabbitmq

type Config struct {
	Username string
	Password string
	Hostname string
	Port     int
}

type Consumer struct {
	Name     string
	Exchange Exchange

	DoneChan chan error
	// contains filtered or unexported fields
}

type Exchange struct {
	Name       string
	Type       string
	RoutingKey string
}

type Handler interface {
	HandleMessage(message *amqp.Delivery) error
}

type HandlerFunc func(message *amqp.Delivery) error

type Producer struct {
	Exchange Exchange
	// contains filtered or unexported fields
}