rmqsimpleservice

Documentation

Index

• type ConnectConfig
• type OperationCallback
• type RmqService
  • func Init(config *ConnectConfig) *RmqService
  • func (r *RmqService) Consume(ctx context.Context, qName string) (<-chan amqp.Delivery, error)
  • func (r *RmqService) GetConfig() *ConnectConfig
  • func (r *RmqService) Publish(message []byte) bool
• type SenderWorker
  • func GetSender(worker *Worker) *SenderWorker
  • func (senderWorker *SenderWorker) GetHandle() OperationCallback
• type Worker
  • func (worker *Worker) Run(callback func(worker *Worker, msg amqp091.Delivery))

Types

type ConnectConfig

type ConnectConfig struct {
	Login, Password, Ip, Port, QueueTitle, ExchangeTitle, ExchangeType, RoutingKey, ConsumerTitle string
	Durable, AutoDelete, Exclusive, NoWait, Internal, Mandatory, Immediate, AutoAck, NoLocal      bool
	Args                                                                                          amqp.Table
}

type OperationCallback

type OperationCallback func(*Worker, amqp091.Delivery)

type RmqService

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

func Init

func Init(config *ConnectConfig) *RmqService

func (*RmqService) Consume

func (r *RmqService) Consume(ctx context.Context, qName string) (<-chan amqp.Delivery, error)

func (*RmqService) GetConfig

func (r *RmqService) GetConfig() *ConnectConfig

func (*RmqService) Publish

func (r *RmqService) Publish(message []byte) bool

type SenderWorker

type SenderWorker struct {
	*Worker
}

func GetSender

func GetSender(worker *Worker) *SenderWorker

GetSender

func (*SenderWorker) GetHandle

func (senderWorker *SenderWorker) GetHandle() OperationCallback

GetHandle returns the message handling function (here as an example)

type Worker

type Worker struct {
	QueueTitle string
	Rmq        *RmqService
}

func (*Worker) Run

func (worker *Worker) Run(callback func(worker *Worker, msg amqp091.Delivery))