package
0.0.0-20240328104128-aac5e323fe3e
Repository: https://github.com/ravenhuo/go-pkg.git
Documentation: pkg.go.dev
# Functions
Addresses sets the host addresses to be used by the mq.
No description provided by the author
No description provided by the author
DisableAutoAck will disable auto acking of messages after they have been handled.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Retry set retry consume policy.
Secure communication with the mq.
SubscribeContext set context.
SubscribeGroupID sets the name of the queue to share messages on.
Specify TLS Config.
No description provided by the author
# Interfaces
Event is given to a subscription handler for processing.
IBroker is an interface used for asynchronous messaging.
ISubscriber is a convenience return type for the Subscribe method.
# Type aliases
HandlerFunc is used to process messages via a subscription of a topic.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author