amqp

Documentation

Index

• Variables
• func New(ctx context.Context, c Connector, options ...rabbit.SessionOption) (session rabbit.Session)
• func Publish(session rabbit.Session, m rabbit.Message) error
• func RegisterHandler(session rabbit.Session, handlers ...Handler)
• type Connector
  • func (c *Connector) Build(host string, port int, user string, passwd string)
• type Handler

Variables

var (
	ErrEmptyMessageRouter = errors.New("empty router key")
	ErrSessionNil         = errors.New("session is nil")
)

Functions

func New

func New(ctx context.Context, c Connector, options ...rabbit.SessionOption) (session rabbit.Session)

func Publish

func Publish(session rabbit.Session, m rabbit.Message) error

Publish 发送buffer满之后,返回rabbit.ErrPublishTimeout

func RegisterHandler

func RegisterHandler(session rabbit.Session, handlers ...Handler)

Types

type Connector

type Connector struct {
	Conn string
}

func (*Connector) Build

func (c *Connector) Build(host string, port int, user string, passwd string)

type Handler

type Handler interface {

	// Subscribe 订阅
	//
	// payload
	Subscribe(payload interface{}, txHandler rabbit.TxHandler, serverCtx rabbit.ServerContext)
	Router() rabbit.Route
}

Handler 监听一个数据源 Down针对broker是rx