rabbitmq

Documentation

Index

• type ConnectionPool
  • func NewConnectionPool(ctx context.Context, url string, maxConnections, reconnectInterval int, ...) (*ConnectionPool, error)
  • func (pool *ConnectionPool) Close(ctx context.Context) error
  • func (pool *ConnectionPool) GetConnection(ctx context.Context) (*rabbitmq.Conn, error)
  • func (pool *ConnectionPool) ReleaseConnection(conn *rabbitmq.Conn)
• type RabbitMQ
  • func NewRabbitMQ(ctx context.Context, dsn string, maxConnections int, reconnectInterval int, ...) (*RabbitMQ, error)
  • func (r *RabbitMQ) Consumer(ctx context.Context, queueName string, consumerFunc queueLib.ConsumerFunc, ...)
  • func (r *RabbitMQ) Publish(ctx context.Context, message messageLib.IMessage, ...) error
  • func (r *RabbitMQ) RpcRequest(ctx context.Context, key string, data []byte, ...) ([]byte, error)
  • func (r *RabbitMQ) Run(ctx context.Context)
  • func (r *RabbitMQ) Shutdown(ctx context.Context)
  • func (r *RabbitMQ) String() string

Types

type ConnectionPool

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

ConnectionPool 是一个带有计数器和最大连接数限制的连接池

func NewConnectionPool

func NewConnectionPool(ctx context.Context, url string, maxConnections, reconnectInterval int,
	log rabbitmq.Logger, cfg *rabbitmq.Config) (*ConnectionPool, error)

NewConnectionPool 创建一个新的带有计数器和最大连接数限制的连接池

func (*ConnectionPool) Close

func (pool *ConnectionPool) Close(ctx context.Context) error

func (*ConnectionPool) GetConnection

func (pool *ConnectionPool) GetConnection(ctx context.Context) (*rabbitmq.Conn, error)

GetConnection 从连接池获取一个连接

func (*ConnectionPool) ReleaseConnection

func (pool *ConnectionPool) ReleaseConnection(conn *rabbitmq.Conn)

ReleaseConnection 将连接释放回连接池

type RabbitMQ

type RabbitMQ struct {
	Handler []rabbitmq.Handler

	ConsumerOptions *rabbitmq.ConsumerOptions

	PublisherOptions *rabbitmq.PublisherOptions
	Logger           rabbitmq.Logger
	// contains filtered or unexported fields
}

RabbitMQ cache implement

func NewRabbitMQ

func NewRabbitMQ(
	ctx context.Context,
	dsn string,
	maxConnections int,
	reconnectInterval int,
	cfg *rabbitmq.Config,
	logger rabbitmq.Logger,
) (*RabbitMQ, error)

func (*RabbitMQ) Consumer

func (r *RabbitMQ) Consumer(ctx context.Context, queueName string, consumerFunc queueLib.ConsumerFunc, optionFuncs ...func(*queueLib.ConsumeOptions))

Consumer 监听消费者

func (*RabbitMQ) Publish

func (r *RabbitMQ) Publish(ctx context.Context, message messageLib.IMessage, optionFuncs ...func(*queueLib.PublishOptions)) error

Publish 消息入生产者

func (*RabbitMQ) RpcRequest

func (r *RabbitMQ) RpcRequest(ctx context.Context, key string, data []byte, optionFuncs ...func(*queueLib.ClientOptions)) ([]byte, error)

RpcRequest AMQP RPC Request

func (*RabbitMQ) Run

func (r *RabbitMQ) Run(ctx context.Context)

func (*RabbitMQ) Shutdown

func (r *RabbitMQ) Shutdown(ctx context.Context)

func (*RabbitMQ) String

func (r *RabbitMQ) String() string