Versions in this module Expand all Collapse all v0 v0.0.3 Aug 26, 2024 Changes in this version + func GetRocketQueue(diName string) queue.Queue + type RocketMQClient struct + Consumer rocketmq.PushConsumer + Producer rocketmq.Producer + type RocketQueue struct + func (m *RocketQueue) AckMsg(ctx context.Context, key string, token string) (bool, error) + func (m *RocketQueue) BatchEnqueue(ctx context.Context, key string, messages []string) (bool, error) + func (m *RocketQueue) Dequeue(ctx context.Context, key string) (message string, tag string, token string, dequeueCount int64, err error) + func (m *RocketQueue) Enqueue(ctx context.Context, key string, message string) (bool, error)
Go to main page