amqp10

Documentation

Index

• type Amqp10Consumer
  • func NewConsumer(ctx context.Context, 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, consumerReady chan bool)
  • func (c *Amqp10Consumer) Stop(reason string)
• type Amqp10Publisher
  • func NewPublisher(ctx context.Context, cfg config.Config, id int) *Amqp10Publisher
  • func (p *Amqp10Publisher) Connect()
  • func (p *Amqp10Publisher) CreateSender()
  • func (p *Amqp10Publisher) Send(ctx context.Context) error
  • func (p *Amqp10Publisher) Start(ctx context.Context, publisherReady chan bool, startPublishing chan bool)
  • func (p *Amqp10Publisher) StartPublishing(ctx context.Context) string
  • 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(ctx context.Context, 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, consumerReady 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(ctx context.Context, 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(ctx context.Context) error

func (*Amqp10Publisher) Start

func (p *Amqp10Publisher) Start(ctx context.Context, publisherReady chan bool, startPublishing chan bool)

func (*Amqp10Publisher) StartPublishing

func (p *Amqp10Publisher) StartPublishing(ctx context.Context) string

func (*Amqp10Publisher) Stop

func (p *Amqp10Publisher) Stop(reason string)