amqp091

Documentation

Index

• type Amqp091Consumer
  • func NewConsumer(ctx context.Context, cfg config.Config, id int) *Amqp091Consumer
  • func (c *Amqp091Consumer) Connect()
  • func (c *Amqp091Consumer) Start(consumerReady chan bool)
  • func (c *Amqp091Consumer) Stop(reason string)
  • func (c *Amqp091Consumer) Subscribe()
• type Amqp091Publisher
  • func NewPublisher(ctx context.Context, cfg config.Config, id int) *Amqp091Publisher
  • func (p *Amqp091Publisher) Connect()
  • func (p *Amqp091Publisher) SendAsync(n uint64) error
  • func (p *Amqp091Publisher) Start(publisherReady chan bool, startPublishing chan bool)
  • func (p *Amqp091Publisher) StartPublishing() string
  • func (p *Amqp091Publisher) Stop(reason string)

Types

type Amqp091Consumer

type Amqp091Consumer struct {
	Id         int
	Connection *amqp091.Connection
	Channel    *amqp091.Channel
	Terminus   string
	Messages   <-chan amqp091.Delivery
	Config     config.Config
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer(ctx context.Context, cfg config.Config, id int) *Amqp091Consumer

func (*Amqp091Consumer) Connect

func (c *Amqp091Consumer) Connect()

func (*Amqp091Consumer) Start

func (c *Amqp091Consumer) Start(consumerReady chan bool)

func (*Amqp091Consumer) Stop

func (c *Amqp091Consumer) Stop(reason string)

func (*Amqp091Consumer) Subscribe

func (c *Amqp091Consumer) Subscribe()

type Amqp091Publisher

type Amqp091Publisher struct {
	Id         int
	Connection *amqp091.Connection
	Channel    *amqp091.Channel

	Config config.Config
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher(ctx context.Context, cfg config.Config, id int) *Amqp091Publisher

func (*Amqp091Publisher) Connect

func (p *Amqp091Publisher) Connect()

func (*Amqp091Publisher) SendAsync

func (p *Amqp091Publisher) SendAsync(n uint64) error

func (*Amqp091Publisher) Start

func (p *Amqp091Publisher) Start(publisherReady chan bool, startPublishing chan bool)

func (*Amqp091Publisher) StartPublishing

func (p *Amqp091Publisher) StartPublishing() string

func (*Amqp091Publisher) Stop

func (p *Amqp091Publisher) Stop(reason string)