amqp

type AmqpClientCommon struct {
	Context     framework.ContextData
	Name        string
	Url         string
	Timeout     int
	Params      []Param
	Pod         *v1.Pod
	TimedOut    bool
	Interrupted bool
	FinalResult *ResultData
	Mutex       sync.Mutex
}

type Client interface {
	Deploy() error
	Status() ClientStatus
	Running() bool
	Interrupt()
	Wait() ClientStatus
	Result() ResultData
}

type ClientStatus int

type Message struct {
	Address       string
	Content       string
	ContentSHA1   string
	Id            string
	CorrelationId string
	ReplyTo       string
	Expiration    int
	Priority      int
	Ttl           int
	UserId        string
}

type Param struct {
	Name, Value string
}

type ResultData struct {
	Messages  []Message
	Delivered int
	Released  int
	Rejected  int
	Modified  int
	Accepted  int
}