rabbitmq

type Admin struct {
	// contains filtered or unexported fields
}

type ConsumeHandle func(message string) error

type ConsumeHandler interface {
	Consume(message string) error
}

type ConsumerConf struct {
	Name      string
	AutoAck   bool `json:",default=true"`
	Exclusive bool `json:",default=false"`
	// Set to true, which means that messages sent by producers in the same connection
	// cannot be delivered to consumers in this connection.
	NoLocal bool `json:",default=false"`
	// Whether to block processing
	NoWait bool `json:",default=false"`
}

type ExchangeConf struct {
	ExchangeName string
	Type         string `json:",options=direct|fanout|topic|headers"` // exchange type
	Durable      bool   `json:",default=true"`
	AutoDelete   bool   `json:",default=false"`
	Internal     bool   `json:",default=false"`
	NoWait       bool   `json:",default=false"`
	Queues       []QueueConf
}

type QueueConf struct {
	Name       string
	Durable    bool `json:",default=true"`
	AutoDelete bool `json:",default=false"`
	Exclusive  bool `json:",default=false"`
	NoWait     bool `json:",default=false"`
}

type RabbitConf struct {
	Username string
	Password string
	Host     string
	Port     int
	VHost    string `json:",optional"`
}

type RabbitListener struct {
	// contains filtered or unexported fields
}

type RabbitListenerConf struct {
	RabbitConf
	ListenerQueues []ConsumerConf
}

type RabbitMqSender struct {
	ContentType string
	// contains filtered or unexported fields
}

type RabbitSenderConf struct {
	RabbitConf
	ContentType string `json:",default=text/plain"` // MIME content type
}

type Sender interface {
	Send(exchange string, routeKey string, msg []byte) error
}