Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAdmin ¶
NewAdmin returns a new RocketMQ admin with given configuration. It's the caller's responsibility to close the admin when it's no longer needed.
func NewProducer ¶
NewProducer returns a new RocketMQ producer with given configuration. It's the caller's responsibility to start and shutdown the producer.
func NewPushConsumer ¶
NewPushConsumer returns a new RocketMQ push consumer with given configuration. It's the caller's responsibility to start and shutdown the consumer.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.