event

Documentation

Index

• type ConformationListener
• type Listener
• type Router

Types

type ConformationListener

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

type Listener

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

type Router

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
}