rabbit

Documentation

Index

• Variables
• type ConfigOption
  • func WithConsumer(name string, prefetchCount int) ConfigOption
  • func WithStateReporter(f func(bool)) ConfigOption
• type MessageBroker
  • func NewMessageBroker(address, user, password, queue string, opts ...ConfigOption) (*MessageBroker, error)
  • func (mb *MessageBroker) Close() error
  • func (mb *MessageBroker) Consume(ctx context.Context, out proto.Message) error
  • func (mb *MessageBroker) Publish(ctx context.Context, in proto.Message) error
• type PublishConsumer

Variables

var (
	ErrClosedUnexpectedly = errors.New("channel closed unexpectedly")
	ErrNotInitialized     = errors.New("not initialized")
)

Types

type ConfigOption

type ConfigOption func(*MessageBroker)

func WithConsumer

func WithConsumer(name string, prefetchCount int) ConfigOption

func WithStateReporter

func WithStateReporter(f func(bool)) ConfigOption

type MessageBroker

type MessageBroker struct {
	sync.RWMutex

	Connection *amqp.Connection
	Channel    *amqp.Channel
	Queue      *amqp.Queue

	Msgs <-chan amqp.Delivery
	// contains filtered or unexported fields
}

func NewMessageBroker

func NewMessageBroker(address, user, password, queue string, opts ...ConfigOption) (*MessageBroker, error)

func (*MessageBroker) Close

func (mb *MessageBroker) Close() error

func (*MessageBroker) Consume

func (mb *MessageBroker) Consume(ctx context.Context, out proto.Message) error

func (*MessageBroker) Publish

func (mb *MessageBroker) Publish(ctx context.Context, in proto.Message) error

type PublishConsumer

type PublishConsumer interface {
	Publish(ctx context.Context, in proto.Message) error
	Consume(ctx context.Context, out proto.Message) error
}