mqtrace

Documentation

Index

• type ConsumeMessageContext
• type ConsumeMessageHook
• type SendMessageContext
  • func NewSendMessageContext() *SendMessageContext
• type SendMessageHook

Types

type ConsumeMessageContext

type ConsumeMessageContext struct {
	ConsumerGroup  string
	Topic          string
	QueueId        int32
	ClientHost     string
	StoreHost      string
	MessageIds     map[string]int64
	BodyLength     int
	Success        bool
	Status         string
	MqTraceContext interface{}
}

type ConsumeMessageHook

type ConsumeMessageHook interface {
	HookName() string
	ConsumeMessageBefore(context *ConsumeMessageContext)
	ConsumeMessageAfter(context *ConsumeMessageContext)
}

ConsumeMessageHook 消费消息回调 Author rongzhihong Since 2017/9/5

type SendMessageContext

type SendMessageContext struct {
	ProducerGroup string
	Topic         string
	MsgId         string
	OriginMsgId   string
	QueueId       int32
	QueueOffset   int64
	BrokerAddr    string
	BornHost      string
	BodyLength    int
	Code          int
	ErrorMsg      string
	MsgProps      string
}

SendMessageContext 消息发送上下文 Author gaoyanlei Since 2017/8/15

func NewSendMessageContext

func NewSendMessageContext() *SendMessageContext

NewSendMessageContext 初始化 Author gaoyanlei Since 2017/8/15

type SendMessageHook

type SendMessageHook interface {
	HookName() string
	SendMessageBefore(context *SendMessageContext)
	SendMessageAfter(context *SendMessageContext)
}

SendMessageHook 发送消息回调 Author rongzhihong Since 2017/9/5