broker

package

v2.3.2+incompatible Latest Latest Go to latest Published: Jul 28, 2021 License: AGPL-3.0 Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

func EnableHTTP()

EnableSTAN enables the http broker

func EnableMemory()

func EnableNATS()

EnableNATS enables the nats broker

func EnableSTAN()

EnableSTAN enables the stan broker

func EnableService(hostname, port string)

func NewBroker(b broker.Broker, opts ...Option) broker.Broker

NewBroker wraps a standard broker but prevents it from disconnecting while there still is a service running

type Option func(*Options)

Option definition

func BeforeDisconnect(f func() error) Option

BeforeDisconnect registers all functions to be triggered before the broker disconnect

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

Options to the broker

Path	Synopsis
memory
service
stan Package stan provides a NATS Streaming broker	Package stan provides a NATS Streaming broker