package
1.0.23
Repository: https://github.com/nextmicro/next.git
Documentation: pkg.go.dev

# Functions

Addrs sets the host addresses to be used by the broker.
Chain returns a Broker that specifies the chained handler for endpoint.
Codec sets the codec used for encoding/decoding used where a broker does not support headers.
No description provided by the author
DisableAutoAck will disable auto acking of messages after they have been handled.
No description provided by the author
ErrorHandler will catch all broker errors that cant be handled in normal way, for example Codec errors.
No description provided by the author
Logger sets the underline logger.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
PublishContext set context.
Queue sets the name of the queue to share messages on.
Secure communication with the broker.
String returns the name of the Broker.
No description provided by the author
SubscribeContext set context.
SubscribeDisableAutoAck will disable auto acking of messages after they have been handled.
SubscribeQueue sets the name of the queue to share messages on.
TLSConfig Specify TLS Config.
Wrap a broker as a wrapper.

# Variables

DefaultBroker is the default Broker.

# Structs

Message is a message send/received from the broker.
No description provided by the author
No description provided by the author
No description provided by the author

# Interfaces

Broker is an interface used for asynchronous messaging.
Event is given to a subscription handler for processing.
Subscriber is a convenience return type for the Subscribe method.

# Type aliases

Handler 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
Wrapper wraps a Broker and returns a Broker.