Documentation ¶
Index ¶
- Variables
- func NewConnection(url string) (*connection, error)
- func NewConnectionConfig(url string, config ConnectionConfig) (*connection, error)
- func NewConsumer(c messaging.Connection, autoAck bool, exchange, queue string) (*consumer, error)
- func NewConsumerConfig(c messaging.Connection, autoAck bool, exchange, queue string, ...) (*consumer, error)
- func NewProducer(c messaging.Connection, exchange string) (*producer, error)
- func NewProducerConfig(c messaging.Connection, exchange string, config ProducerConfig) (*producer, error)
- func NewUUIDv4() (string, error)
- type ConnectionConfig
- type ConsumerConfig
- type ProducerConfig
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNotAcked = errors.New("message was not acked")
ErrNotAcked indicated that published messages was not acked by RabbitMQ
View Source
var ErrTimedout = errors.New("message was timed out")
Functions ¶
func NewConnection ¶
NewConnection returns an AMQP Connection. Uses a default ConnectionConfig with 2 second of reconnect interval.
func NewConnectionConfig ¶
func NewConnectionConfig(url string, config ConnectionConfig) (*connection, error)
NewConnectionConfig returns an AMQP Connection.
func NewConsumer ¶
func NewConsumer(c messaging.Connection, autoAck bool, exchange, queue string) (*consumer, error)
NewConsumer returns a new AMQP Consumer. Uses a default ConsumerConfig with 2 second of consume retry interval.
func NewConsumerConfig ¶
func NewConsumerConfig(c messaging.Connection, autoAck bool, exchange, queue string, config ConsumerConfig) (*consumer, error)
NewConsumerConfig returns a new AMQP Consumer.
func NewProducer ¶
func NewProducer(c messaging.Connection, exchange string) (*producer, error)
NewProducer returns a new AMQP Producer. Uses a default ProducerConfig with 2 second of publish interval.
func NewProducerConfig ¶
func NewProducerConfig(c messaging.Connection, exchange string, config ProducerConfig) (*producer, error)
NewProducerConfig returns a new AMQP Producer.
Types ¶
type ConnectionConfig ¶
ConnectionConfig to be used when creating a new connection.
Click to show internal directories.
Click to hide internal directories.