broker

Documentation

Index

• type Broker

Types

type Broker

type Broker interface {
	// Publish sends a payload to a message broker.
	Publish(subject string, payload interface{}) error
	// Subscribe consumes messages from a message broker.
	Subscribe(subject string, handler stan.MsgHandler, subscriberName string) (io.Closer, error)
}

Broker is an interface that wraps queues and message broker.