message

Documentation

Index

• type ConformationListener
• type Listener
• type RawListener
• type Router

Types

type ConformationListener

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

type Listener

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

type RawListener

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

type Router

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
}