amqp10_client

Documentation

Index

• type Amqp10Consumer
  • func NewConsumer(cfg config.Config, id int) *Amqp10Consumer
  • func (c *Amqp10Consumer) Connect(ctx context.Context)
  • func (c *Amqp10Consumer) CreateReceiver(ctx context.Context)
  • func (c *Amqp10Consumer) Start(ctx context.Context, subscribed chan bool)
  • func (c *Amqp10Consumer) Stop(reason string)
• type Amqp10Publisher
  • func NewPublisher(cfg config.Config, id int) *Amqp10Publisher
  • func (p *Amqp10Publisher) Connect()
  • func (p *Amqp10Publisher) CreateSender()
  • func (p *Amqp10Publisher) Send() error
  • func (p *Amqp10Publisher) Start(ctx context.Context)
  • func (p *Amqp10Publisher) StartFullSpeed(ctx context.Context)
  • func (p *Amqp10Publisher) StartIdle(ctx context.Context)
  • func (p *Amqp10Publisher) StartRateLimited(ctx context.Context)
  • func (p *Amqp10Publisher) Stop(reason string)

Types

type Amqp10Consumer

type Amqp10Consumer struct {
	Id         int
	Connection *amqp.Conn
	Session    *amqp.Session
	Receiver   *amqp.Receiver
	Terminus   string
	Config     config.Config
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer(cfg config.Config, id int) *Amqp10Consumer

func (*Amqp10Consumer) Connect

func (c *Amqp10Consumer) Connect(ctx context.Context)

func (*Amqp10Consumer) CreateReceiver

func (c *Amqp10Consumer) CreateReceiver(ctx context.Context)

func (*Amqp10Consumer) Start

func (c *Amqp10Consumer) Start(ctx context.Context, subscribed chan bool)

func (*Amqp10Consumer) Stop

func (c *Amqp10Consumer) Stop(reason string)

type Amqp10Publisher

type Amqp10Publisher struct {
	Id         int
	Connection *amqp.Conn
	Session    *amqp.Session
	Sender     *amqp.Sender
	Terminus   string
	Config     config.Config
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher(cfg config.Config, id int) *Amqp10Publisher

func (*Amqp10Publisher) Connect

func (p *Amqp10Publisher) Connect()

func (*Amqp10Publisher) CreateSender

func (p *Amqp10Publisher) CreateSender()

func (*Amqp10Publisher) Send

func (p *Amqp10Publisher) Send() error

func (*Amqp10Publisher) Start

func (p *Amqp10Publisher) Start(ctx context.Context)

func (*Amqp10Publisher) StartFullSpeed

func (p *Amqp10Publisher) StartFullSpeed(ctx context.Context)

func (*Amqp10Publisher) StartIdle

func (p *Amqp10Publisher) StartIdle(ctx context.Context)

func (*Amqp10Publisher) StartRateLimited

func (p *Amqp10Publisher) StartRateLimited(ctx context.Context)

func (*Amqp10Publisher) Stop

func (p *Amqp10Publisher) Stop(reason string)