pubsub

Documentation

Index

• type PubSub
  • func New(cfg *config.AMQPConfig) *PubSub
  • func (p *PubSub) Connect() error
  • func (p *PubSub) Initialize() error
  • func (p *PubSub) Publish(routingKey string, contentType string, body []byte) error
  • func (p *PubSub) PublishJSON(routingKey string, data interface{}) error
  • func (p *PubSub) QueueDeclare(name string) (amqp.Queue, error)
  • func (p *PubSub) SetupChannel() error

Types

type PubSub

type PubSub struct {
	Config  *config.AMQPConfig
	Conn    *amqp.Connection
	Channel *amqp.Channel
}

func New

func New(cfg *config.AMQPConfig) *PubSub

func (*PubSub) Connect

func (p *PubSub) Connect() error

func (*PubSub) Initialize

func (p *PubSub) Initialize() error

func (*PubSub) Publish

func (p *PubSub) Publish(routingKey string, contentType string, body []byte) error

Publish a byte string using a given routing key (in our case, always the queue name)

func (*PubSub) PublishJSON

func (p *PubSub) PublishJSON(routingKey string, data interface{}) error

Shortcut to publishing arbitrary interfaces

as JSON

func (*PubSub) QueueDeclare

func (p *PubSub) QueueDeclare(name string) (amqp.Queue, error)

Setup a persistent queue

func (*PubSub) SetupChannel

func (p *PubSub) SetupChannel() error