event

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

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

type Router interface {
	SendAll(batch *p_buff.EventBatch, attributes ...string) error
	SubscribeAll(listener Listener, attributes ...string) (queue.Monitor, error)
	SubscribeAllWithManualAck(listener ConformationListener, attributes ...string) (queue.Monitor, error)
	io.Closer
}