mq

Documentation

Index

• type Consumer
  • func NewConsumerRocket(ctx context.Context, nameServer []string, namespace string, groupId string, ...) (Consumer, error)
• type ConsumerMessage
• type Producer
  • func NewProducerRocket(ctx context.Context, nameServer []string, namespace string, groupId string, ...) (Producer, error)
• type ProducerMessage

Types

type Consumer

type Consumer interface {
	Start(ctx context.Context) error
	Close(ctx context.Context) error
	Subscribe(ctx context.Context, topic string, tag string, f func(context.Context, ...*ConsumerMessage) bool) error
	Unsubscribe(ctx context.Context, topic string) error
}

func NewConsumerRocket

func NewConsumerRocket(ctx context.Context, nameServer []string, namespace string, groupId string, options ...option.ConsumerFunc) (Consumer, error)

type ConsumerMessage

type ConsumerMessage = message.Consumer

type Producer

type Producer interface {
	Start(ctx context.Context) error
	Close(ctx context.Context) error
	SendMsg(ctx context.Context, topic string, msg *ProducerMessage) error
}

func NewProducerRocket

func NewProducerRocket(ctx context.Context, nameServer []string, namespace string, groupId string, options ...option.ProducerFunc) (Producer, error)

type ProducerMessage

type ProducerMessage = message.Producer