amqp

Documentation

Index

• Variables
• func Consume(deliveryTag string, handlerFunc HandlerFunc, count int) (*sync.WaitGroup, *sync.WaitGroup)
• func ConsumeForever(deliveryTag string, handlerFunc HandlerFunc) (*sync.WaitGroup, *sync.WaitGroup)
• func ConsumeSingle(deliveryTag string, handlerFunc HandlerFunc) (*sync.WaitGroup, *sync.WaitGroup)
• func Decode(in []byte, typ interface{}) interface{}
• func Encode(in interface{}) []byte
• func GetChannel(name string) (*amqp.Channel, error)
• func Publish(routingKey string, msg amqp.Publishing) error
• func PublishPb(msg interface{})
• func PublishPbWithChannel(c *amqp.Channel, msg interface{})
• func PublishPbWithRoutingKey(msg interface{}, routingKey string)
• func PublishWithChannel(c *amqp.Channel, routingKey string, msg amqp.Publishing) error
• func StartServerListener()
• type Delivery
• type HandlerFunc

Variables

var (
	ConnectionIdentifier string

	InstanceId string

	AmqpHost string
	AmqpUser string
	AmqpPass string
	AmqpPort int
)

Functions

func Consume

func Consume(deliveryTag string, handlerFunc HandlerFunc, count int) (*sync.WaitGroup, *sync.WaitGroup)

func ConsumeForever

func ConsumeForever(deliveryTag string, handlerFunc HandlerFunc) (*sync.WaitGroup, *sync.WaitGroup)

func ConsumeSingle

func ConsumeSingle(deliveryTag string, handlerFunc HandlerFunc) (*sync.WaitGroup, *sync.WaitGroup)

func Decode

func Decode(in []byte, typ interface{}) interface{}

func Encode

func Encode(in interface{}) []byte

func GetChannel

func GetChannel(name string) (*amqp.Channel, error)

func Publish

func Publish(routingKey string, msg amqp.Publishing) error

func PublishPb

func PublishPb(msg interface{})

func PublishPbWithChannel

func PublishPbWithChannel(c *amqp.Channel, msg interface{})

func PublishPbWithRoutingKey

func PublishPbWithRoutingKey(msg interface{}, routingKey string)

func PublishWithChannel

func PublishWithChannel(c *amqp.Channel, routingKey string, msg amqp.Publishing) error

func StartServerListener

func StartServerListener()

Types

type Delivery

type Delivery struct {
	Message amqp.Delivery
}

A dumb Delivery wrapper, so dependencies on this lib don't have to depened on the streadway lib

type HandlerFunc

type HandlerFunc func(d Delivery)