Documentation
¶
Overview ¶
Package rabbitmq provides a RabbitMQ driver for ncore/data.
This driver uses amqp091-go (github.com/rabbitmq/amqp091-go) as the underlying AMQP 0-9-1 client library. It registers itself automatically when imported:
import _ "github.com/ncobase/ncore/data/rabbitmq"
The driver supports RabbitMQ connection configuration including connection URLs, virtual hosts, and connection parameters.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitMQ ¶
type RabbitMQ struct {
// contains filtered or unexported fields
}
RabbitMQ represents RabbitMQ implementation
func NewRabbitMQ ¶
func NewRabbitMQ(conn *amqp.Connection) *RabbitMQ
NewRabbitMQ creates new RabbitMQ connection
func NewRabbitMQWithConfig ¶
func NewRabbitMQWithConfig(conn *amqp.Connection, messaging *config.Messaging) *RabbitMQ
NewRabbitMQWithConfig creates new RabbitMQ with messaging config
func (*RabbitMQ) ConsumeMessages ¶
ConsumeMessages consumes messages from RabbitMQ
func (*RabbitMQ) IsConnected ¶
IsConnected checks if the RabbitMQ connection is valid
Source Files
Click to show internal directories.
Click to hide internal directories.