rabbitUtils

Documentation

Index

• func BoundQueueToExchange(rabbit *RabbitRep, routingKey string) error
• func CreateExchange(rabbit *RabbitRep) error
• func Receive(rabbit *RabbitRep, queueName string, function fn)
• func Send(rabbit *RabbitRep, data string, ct string) error
• type RabbitExchange
• type RabbitQueue
• type RabbitRep
  • func InitializeRabbit(uri string, exchange RabbitExchange, queues []RabbitQueue) (*RabbitRep, error)

Functions

func BoundQueueToExchange

func BoundQueueToExchange(rabbit *RabbitRep, routingKey string) error

func CreateExchange

func CreateExchange(rabbit *RabbitRep) error

func Receive

func Receive(rabbit *RabbitRep, queueName string, function fn)

func Send

func Send(rabbit *RabbitRep, data string, ct string) error

Types

type RabbitExchange

type RabbitExchange struct {
	// contains filtered or unexported fields
}

type RabbitQueue

type RabbitQueue struct {
	// contains filtered or unexported fields
}

type RabbitRep

type RabbitRep struct {
	// contains filtered or unexported fields
}

func InitializeRabbit

func InitializeRabbit(uri string, exchange RabbitExchange, queues []RabbitQueue) (*RabbitRep, error)