app

Documentation

Index

• Constants
• Variables
• func AddHandle(topic string, h nsq.HandlerFunc) error
• func Run() error
• func Stop()

Constants

const VERSION = "1.0.0"

Version Current Worker

Variables

var (
	// ProduceWorker 用于发送信息到 NSQD
	ProduceWorker *message.ProduceWorker
)

Functions

func AddHandle

func AddHandle(topic string, h nsq.HandlerFunc) error

AddHandle Add a new topic handle. 此说明有可实现的 Handle 来处理 Topic 信息,因此将订阅该主题处理消息

func Run

func Run() error

Run APP

func Stop

func Stop()

Stop App