amqp

type AmqpClient interface {
	Connect() (cha *amqp.Channel, err error)
	Close()
}

type Channel struct {
	*amqp.Channel
}

type NewChannel func() (chn *Channel)

type Properties struct {
	at.ConfigurationProperties `value:"amqp"`

	Port      int    `json:"port" default:"5672"`
	Username  string `json:"username" default:"guest"`
	Password  string `json:"password" default:"guest"`
	Host      string `json:"host" default:"127.0.0.1"`
	QueueName string `json:"queueName" default:"my-queue"`
	Exchange  string `json:"exchange" default:"my-exchange"`
	SleepTime int64  `json:"sleepTime" default:"3*1e9"`
}