rabbitmq

type AMQPChannel struct {
	*amqp.Channel
}

type Channel interface {
	// Send sends body to a message queue.
	Send(name string, body []byte) error
	// Receive immediately starts delivering queued messages.
	Receive(name string) (<-chan amqp.Delivery, error)
	// SendToExchange sends body to an exchange.
	SendToExchange(name string, excType string, body []byte) error
	// Receive immediately starts delivering queued messages.
	ReceiveOnExchange(name string, excType string) (<-chan amqp.Delivery, error)
}

type MockAMQPChannel struct{}