message

package

v0.1.0-rc4 Latest Latest Go to latest Published: Apr 28, 2020 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

View Source

var SupportedBrokers = []Broker{AmqpBroker}

func ValidationOpts(opts *Options) error

type Broker string

const AmqpBroker Broker = "amqp"

type Options struct {
	Broker Broker

	AmqpURI   string
	AmqpQueue string
}

type Producer interface {
	Publish(message interface{}) error
	Close() error
}

func NewProducer(opts *Options) (Producer, error)

Path	Synopsis
amqp