rabbitmq

type AMQPConfig struct {
	ConnConfigName  string
	Queue           string
	QueueDurable    bool
	BindingExchange bool
	ExchangeName    string
	ExchangeType    string
	BindingKey      string
	QueueAutoDelete bool
}

type AMQPConsumerCallback func(amqp.Delivery) *mqenv.MQPublishMessage

type RabbitConsumerProxy struct {
	Queue       string
	Callback    AMQPConsumerCallback
	ConsumerTag string
	AutoAck     bool
	Exclusive   bool
	NoLocal     bool
	NoWait      bool
	Arguments   amqp.Table
	// contains filtered or unexported fields
}

type RabbitMQ struct {
	Name       string
	Publish    chan *mqenv.MQPublishMessage
	Consume    chan *RabbitConsumerProxy
	Done       chan error
	Channel    *amqp.Channel
	Conn       *amqp.Connection
	Config     *AMQPConfig
	ConnConfig *mqenv.MQConnectorConfig
	Close      chan interface{}
	// contains filtered or unexported fields
}

type RabbitQueueStatus struct {
	RefreshingTime int64
	QueueName      string
	Consumers      int
	Messages       int
}

type RabbitRPC struct {
	RabbitMQ
	Deliveries <-chan amqp.Delivery
	RPCType    int
}