rabbitmq

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

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

type ConsumerOption func(*Consumer)

type MapChild struct {
	Name string `json:"name"`
	Age  int    `json:"age"`
}

type MapTest struct {
	Name  string   `json:"name"`
	Age   int      `json:"age"`
	Child MapChild `json:"child"`
}

type Option func(*Connection)

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

type QueueExchange struct {
	QuName string // 队列名称
	RtKey  string // key值
	ExName string // 交换机名称
	ExType string // 交换机类型
	Dns    string //链接地址
}

type RabbitMQ struct {
	Channel *amqp.Channel

	QueueName    string // 队列名称
	RoutingKey   string // key名称
	ExchangeName string // 交换机名称
	ExchangeType string // 交换机类型
	// contains filtered or unexported fields
}

type Receiver interface {
	Consumer([]byte) error
	FailAction(error, []byte) error
}

type State int

type TestReceive struct {
}