rocketmq

package
v0.0.0-...-32ff608 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 28, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BroadCastingMessageSubscribeHandler 

type BroadCastingMessageSubscribeHandler struct {
	// contains filtered or unexported fields
}

BroadCastingMessageSubscribeHandler message consume handler of BroadCasting mode

type ClusteringMessageSubscribeHandler 

type ClusteringMessageSubscribeHandler struct {
	// contains filtered or unexported fields
}

ClusteringMessageSubscribeHandler message consume handler of Clustering mode

type Consumer 

type Consumer struct {
	// contains filtered or unexported fields
}

func NewConsumer 

func NewConsumer() *Consumer

NewConsumer get new consumer, needs to be Initiated before using

func (*Consumer) InitConsumer 

func (c *Consumer) InitConsumer(properties map[string]string) error

InitConsumer init consumer by properties

func (*Consumer) IsClosed 

func (c *Consumer) IsClosed() bool

IsClosed check if consumer is closed

func (*Consumer) IsStarted 

func (c *Consumer) IsStarted() bool

IsStarted check if consumer is started

func (*Consumer) RegisterEventListener 

func (c *Consumer) RegisterEventListener(listener *connector.EventListener)

RegisterEventListener listener's Consume function will be called when message is being consumed

func (*Consumer) Shutdown 

func (c *Consumer) Shutdown() error

Shutdown terminate the consumer

func (*Consumer) Start 

func (c *Consumer) Start() error

Start make consumer started

func (*Consumer) Subscribe 

func (c *Consumer) Subscribe(topicName string) error

Subscribe subscribe topic

func (*Consumer) Unsubscribe 

func (c *Consumer) Unsubscribe(topicName string) error

Unsubscribe unsubscribe topic

func (*Consumer) UpdateOffset 

func (c *Consumer) UpdateOffset(ctx context.Context, events []*ce.Event) error

UpdateOffset always return error, since currently RocketMQ client doesn't support manual offset updating

type Factory 

type Factory struct {
	plugin.Plugin
	// contains filtered or unexported fields
}

func (*Factory) GetConsumer 

func (f *Factory) GetConsumer() (connector.Consumer, error)

func (*Factory) GetProducer 

func (f *Factory) GetProducer() (connector.Producer, error)

func (*Factory) GetResource 

func (f *Factory) GetResource() (connector.Resource, error)

func (*Factory) Setup 

func (f *Factory) Setup(name string, dec plugin.Decoder) error

func (*Factory) Type 

func (f *Factory) Type() string

type Producer 

type Producer struct {
	// contains filtered or unexported fields
}

func NewProducer 

func NewProducer() *Producer

NewProducer get new producer, needs to be Initiated before using

func (*Producer) CheckTopicExist 

func (p *Producer) CheckTopicExist(topicName string) (bool, error)

CheckTopicExist RocketMQ go-sdk doesn't support topic check

func (*Producer) InitProducer 

func (p *Producer) InitProducer(properties map[string]string) error

InitProducer init producer by properties

func (*Producer) IsClosed 

func (p *Producer) IsClosed() bool

IsClosed check if producer is closed

func (*Producer) IsStarted 

func (p *Producer) IsStarted() bool

IsStarted check if producer is started

func (*Producer) Publish 

func (p *Producer) Publish(ctx context.Context, event *ce.Event, callback *connector.SendCallback) error

Publish async publish message to broker

func (*Producer) Reply 

func (p *Producer) Reply(ctx context.Context, event *ce.Event, callback *connector.SendCallback) error

Reply async send message to reply

func (*Producer) Request 

func (p *Producer) Request(ctx context.Context, event *ce.Event, callback *connector.RequestReplyCallback,
	timeout time.Duration) error

Request async request message

func (*Producer) SendOneway 

func (p *Producer) SendOneway(ctx context.Context, event *ce.Event) error

SendOneway async send message without callback

func (*Producer) SetExtFields 

func (p *Producer) SetExtFields() error

SetExtFields do nothing, RocketMQ go-sdk doesn't support dynamic client option modify

func (*Producer) Shutdown 

func (p *Producer) Shutdown() error

Shutdown terminate the producer

func (*Producer) Start 

func (p *Producer) Start() error

Start make producer started

type Resource 

type Resource struct {
}

func (Resource) Init 

func (r Resource) Init() error

func (Resource) Release 

func (r Resource) Release() error

type SendCallback 

type SendCallback func(ctx context.Context, result *primitive.SendResult, err error)

type SubscribeHandler 

type SubscribeHandler interface {
	// contains filtered or unexported methods
}

SubscribeHandler interface of message consume handler

Source Files

View all Source files

Directories

Path Synopsis
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.