consumer

Documentation

Index

• Constants
• type Consumer
  • func (consumer *Consumer) Close()
  • func (consumer *Consumer) Start()

Constants

const (
	ACK     = types.Result(0)
	NACK    = types.Result(1)
	REQUEUE = types.Result(2)
	REJECT  = types.Result(3)

	STATUS_START = 1
	STATUS_CLOSE = 0
)

Types

type Consumer

type Consumer struct {
	*types.Consumer

	sync.Mutex
	// contains filtered or unexported fields
}

func (*Consumer) Close

func (consumer *Consumer) Close()

关闭监听

func (*Consumer) Start

func (consumer *Consumer) Start()