rabbitmq

Documentation

Index

• type RabbitMQ
  • func NewRabbitMQ(ctx context.Context, dsn string, reconnectInterval int, cfg *rabbitmq.Config, ...) (*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 RabbitMQ

type RabbitMQ struct {
	Url               string
	ReconnectInterval int
	Handler           []rabbitmq.Handler
	Config            rabbitmq.Config

	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,
	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