Documentation ¶
Index ¶
- func Auth(username string, password string) broker.Option
- func ConnectHeaders(h map[string]string) broker.Option
- func ConnectTimeout(ct time.Duration) broker.Option
- func Durable() broker.SubscribeOption
- func NewBroker(opts ...broker.Option) broker.Broker
- func Receipt(ct time.Duration) broker.PublishOption
- func SubscribeHeaders(h map[string]string) broker.SubscribeOption
- func SuppressContentLength(ct time.Duration) broker.PublishOption
- func VirtualHost(h string) broker.Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConnectHeaders ¶
ConnectHeaders adds headers for the connection
func ConnectTimeout ¶
ConnectTimeout sets the connection timeout duration
func Receipt ¶
func Receipt(ct time.Duration) broker.PublishOption
Receipt requests a receipt for the delivery should be received
func SubscribeHeaders ¶
func SubscribeHeaders(h map[string]string) broker.SubscribeOption
SubscribeHeaders sets headers for subscriptions
func SuppressContentLength ¶
func SuppressContentLength(ct time.Duration) broker.PublishOption
SuppressContentLength requests that send does not include a content length
func VirtualHost ¶
VirtualHost adds host header to define the vhost
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.