message

type ConformationListener interface {
	queue.CloseListener
	Handle(delivery queue.Delivery, batch *p_buff.MessageGroupBatch, confirm queue.Confirmation) error
}

type Listener interface {
	queue.CloseListener
	Handle(delivery queue.Delivery, batch *p_buff.MessageGroupBatch) error
}

type RawListener interface {
	queue.CloseListener
	Handle(delivery queue.Delivery, data []byte) error
}

type Router interface {
	SendAll(batch *p_buff.MessageGroupBatch, attributes ...string) error
	SendRawAll(payload []byte, attributes ...string) error
	SubscribeAll(listener Listener, attributes ...string) (queue.Monitor, error)
	SubscribeRawAll(listener RawListener, attributes ...string) (queue.Monitor, error)
	SubscribeAllWithManualAck(listener ConformationListener, attributes ...string) (queue.Monitor, error)
	io.Closer
}