rabbitmq

Documentation

Overview

Package rabbitmq Message queue adapter on RabbitMQ.

Index

• type Consumer
  • func NewConsumer(id, parallel int) *Consumer
  • func (o *Consumer) Dispatcher(dispatcher func(*base.Task, *base.Message) bool)
  • func (o *Consumer) Processor() process.Processor
• type Producer
  • func NewProducer() *Producer
  • func (o *Producer) Processor() process.Processor
  • func (o *Producer) Publish(payload *base.Payload) (string, error)
• type Remoter
  • func NewRemoter() *Remoter
  • func (o *Remoter) Build(_ context.Context, _ *base.Task) (err error)
  • func (o *Remoter) BuildById(_ context.Context, _ int) (err error)
  • func (o *Remoter) Destroy(_ context.Context, _ *base.Task) (err error)
  • func (o *Remoter) DestroyById(_ context.Context, _ int) (err error)
  • func (o *Remoter) Processor() process.Processor

Types

type Consumer

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

Consumer 消息消费者.

func NewConsumer

func NewConsumer(id, parallel int) *Consumer

func (*Consumer) Dispatcher

func (o *Consumer) Dispatcher(dispatcher func(*base.Task, *base.Message) bool)

func (*Consumer) Processor

func (o *Consumer) Processor() process.Processor

type Producer

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

Producer 消息生产者.

func NewProducer

func NewProducer() *Producer

func (*Producer) Processor

func (o *Producer) Processor() process.Processor

func (*Producer) Publish

func (o *Producer) Publish(payload *base.Payload) (string, error)

type Remoter

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

Remoter struct for aliyun mns remoter.

func NewRemoter

func NewRemoter() *Remoter

func (*Remoter) Build

func (o *Remoter) Build(_ context.Context, _ *base.Task) (err error)

func (*Remoter) BuildById

func (o *Remoter) BuildById(_ context.Context, _ int) (err error)

func (*Remoter) Destroy

func (o *Remoter) Destroy(_ context.Context, _ *base.Task) (err error)

func (*Remoter) DestroyById

func (o *Remoter) DestroyById(_ context.Context, _ int) (err error)

func (*Remoter) Processor

func (o *Remoter) Processor() process.Processor