mq

package

v1.1.0 Latest Latest Go to latest Published: Oct 21, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

func NewConsumer(opts ...Option) (*Consumer, error)

func (c *Consumer) Start() error

func (c *Consumer) Stop() error

type MessageHandler interface {
	HandleMessage([]byte)
}

type Option func(*Config)

func WithExchange(exchange string) Option

func WithExchangeType(exchangeType string) Option

func WithHandler(h MessageHandler) Option

func WithLogger(logger *logrus.Entry) Option

func WithQueueName(queueName string) Option

func WithURI(uri string) Option