rabbitmq

Documentation

Index

• Constants
• func GenerateQueueName(ex string, topic string) string
• type Broker
  • func (b *Broker) Dial(url string) (RBConnection, error)
  • func (b *Broker) DialTLS(url string, conf *tls.Config) (RBConnection, error)
• type ChannelConsumer
• type ChannelCreator
• type ConnectionManager
  • func (m *ConnectionManager) Channel() (RabbitChannel, error)
  • func (m *ConnectionManager) Connect(connectionUrl string) (<-chan *amqp.Error, error)
  • func (m *ConnectionManager) Disconnect()
• type Connector
• type Exchange
  • func (e *Exchange) Start() error
  • func (e *Exchange) StartConsuming(topic string, deliveries <-chan amqp.Delivery)
  • func (e *Exchange) Stop()
• type ExchangeFactory
  • func (f *ExchangeFactory) Build() (ExchangeOrganizer, error)
  • func (f *ExchangeFactory) WithChanCreator(creator ChannelCreator) Factory
  • func (f *ExchangeFactory) WithExchange(ex *types.Exchange) Factory
  • func (f *ExchangeFactory) WithInvoker(client types.Invoker) Factory
• type ExchangeHandler
• type ExchangeOrganizer
  • func NewExchange(channel ChannelConsumer, client types.Invoker, definition *types.Exchange) ExchangeOrganizer
• type Factory
  • func NewFactory() Factory
• type Manager
  • func NewConnectionManager(dialer RBDialer) Manager
• type QueueHandler
• type RBConnection
• type RBDialer
  • func NewBroker() RBDialer
• type RabbitChannel
• type Starter
• type Stopper

Constants

const MAX_ATTEMPTS = 3

Functions

func GenerateQueueName

func GenerateQueueName(ex string, topic string) string

Types

type Broker

type Broker struct{}

func (*Broker) Dial

func (b *Broker) Dial(url string) (RBConnection, error)

func (*Broker) DialTLS

func (b *Broker) DialTLS(url string, conf *tls.Config) (RBConnection, error)

type ChannelConsumer

type ChannelConsumer interface {
	Consume(queue string, consumer string, autoAck bool, exclusive bool, noLocal bool, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)
	NotifyClose(c chan *amqp.Error) chan *amqp.Error
	Close() error
}

type ChannelCreator

type ChannelCreator interface {
	Channel() (RabbitChannel, error)
}

type ConnectionManager

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

func (*ConnectionManager) Channel

func (m *ConnectionManager) Channel() (RabbitChannel, error)

func (*ConnectionManager) Connect

func (m *ConnectionManager) Connect(connectionUrl string) (<-chan *amqp.Error, error)

func (*ConnectionManager) Disconnect

func (m *ConnectionManager) Disconnect()

type Connector

type Connector interface {
	Connect(connectionUrl string) (<-chan *amqp.Error, error)
	Disconnect()
}

type Exchange

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

func (*Exchange) Start

func (e *Exchange) Start() error

func (*Exchange) StartConsuming

func (e *Exchange) StartConsuming(topic string, deliveries <-chan amqp.Delivery)

func (*Exchange) Stop

func (e *Exchange) Stop()

type ExchangeFactory

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

func (*ExchangeFactory) Build

func (f *ExchangeFactory) Build() (ExchangeOrganizer, error)

func (*ExchangeFactory) WithChanCreator

func (f *ExchangeFactory) WithChanCreator(creator ChannelCreator) Factory

func (*ExchangeFactory) WithExchange

func (f *ExchangeFactory) WithExchange(ex *types.Exchange) Factory

func (*ExchangeFactory) WithInvoker

func (f *ExchangeFactory) WithInvoker(client types.Invoker) Factory

type ExchangeHandler

type ExchangeHandler interface {
	ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error
}

type ExchangeOrganizer

type ExchangeOrganizer interface {
	Starter
	Stopper
}

func NewExchange

func NewExchange(channel ChannelConsumer, client types.Invoker, definition *types.Exchange) ExchangeOrganizer

type Factory

type Factory interface {
	WithInvoker(client types.Invoker) Factory
	WithChanCreator(creator ChannelCreator) Factory
	WithExchange(ex *types.Exchange) Factory
	Build() (ExchangeOrganizer, error)
}

func NewFactory

func NewFactory() Factory

type Manager

type Manager interface {
	Connector
	ChannelCreator
}

func NewConnectionManager

func NewConnectionManager(dialer RBDialer) Manager

type QueueHandler

type QueueHandler interface {
	QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)
	QueueBind(name, key, exchange string, noWait bool, args amqp.Table) error
}

type RBConnection

type RBConnection interface {
	NotifyClose(receiver chan *amqp.Error) chan *amqp.Error
	Close() error
	Channel() (*amqp.Channel, error)
}

type RBDialer

type RBDialer interface {
	Dial(url string) (RBConnection, error)
	DialTLS(url string, conf *tls.Config) (RBConnection, error)
}

func NewBroker

func NewBroker() RBDialer

type RabbitChannel

type RabbitChannel interface {
	ExchangeHandler
	QueueHandler
	ChannelConsumer
}

type Starter

type Starter interface {
	Start() error
}

type Stopper

type Stopper interface {
	Stop()
}