consumerabc

Documentation

Index

• type ConsumerABC
  • func (c *ConsumerABC) HanddlerEvent(asyncHanddler bool, evt *event.Event)
  • func (c *ConsumerABC) RegistHandler(topic string, fn event.Handdler) error
  • func (c *ConsumerABC) UnRegistHandler(topic string) error

Types

type ConsumerABC

type ConsumerABC struct {
	Handdlers     map[string][]event.Handdler
	Handdlerslock sync.RWMutex
}

ConsumerABC 消费者的基类 定义了回调函数的注册操作和执行操作

func (*ConsumerABC) HanddlerEvent

func (c *ConsumerABC) HanddlerEvent(asyncHanddler bool, evt *event.Event)

HanddlerEvent 调用回调函数处理消息 @params asyncHanddler bool 是否异步执行回调函数 @params evt *event.Event 待处理的消息

func (*ConsumerABC) RegistHandler

func (c *ConsumerABC) RegistHandler(topic string, fn event.Handdler) error

RegistHandler 将回调函数注册到指定topic上 @params topic string 注册的topic,topic可以是具体的key也可以是*,*表示监听所有消息 @params fn event.Handdler 注册到topic上的回调函数

func (*ConsumerABC) UnRegistHandler

func (c *ConsumerABC) UnRegistHandler(topic string) error

UnRegistHandler 删除特定topic上注册的回调函数 @params topic string 要取消注册回调的topic,注意`*`取消的只是`*`类型的回调并不是全部取消,要全部取消请使用空字符串