Documentation
¶
Index ¶
- Constants
- func Close(client admin.Admin)
- func DisableClientLogging()
- func NewAdminClient(r *config.RocketMQConfig) (admin.Admin, error)
- func NewProducer(r *config.RocketMQConfig, group string) (rocketmq.Producer, error)
- func NewPushConsumer(r *config.RocketMQConfig, group string) (rocketmq.PushConsumer, error)
- type Message
Constants ¶
View Source
const (
MasterId = int64(0)
)
Variables ¶
This section is empty.
Functions ¶
func DisableClientLogging ¶
func DisableClientLogging()
func NewAdminClient ¶
func NewAdminClient(r *config.RocketMQConfig) (admin.Admin, error)
func NewProducer ¶
func NewPushConsumer ¶
func NewPushConsumer(r *config.RocketMQConfig, group string) (rocketmq.PushConsumer, error)
Types ¶
type Message ¶
type Message struct {
Topic string `json:"topic"`
QueueID *int `json:"queueId"`
QueueOffset int64 `json:"queueOffset"`
MsgID string `json:"msgId"`
OffsetMsgID string `json:"offsetMsgId"`
Properties map[string]string `json:"properties,omitempty"`
BornHost string `json:"bornHost,omitempty"`
StoreHost string `json:"storeHost,omitempty"`
BornTimestamp int64 `json:"bornTimestamp,omitempty"`
StoreTimestamp int64 `json:"storeTimestamp,omitempty"`
ReconsumeTimes int32 `json:"reconsumeTimes,omitempty"`
}
func NewMessage ¶
func NewMessage(msg *primitive.MessageExt, detailed bool) Message
Source Files
Click to show internal directories.
Click to hide internal directories.