cfrabbit

README

CF Rabbit

CF Rabbit is a module that wraps interacting with a RabbitMQ (RMQ) server through Cloud Foundry (CF). It takes care of reconnecting in the background.

It's an adaptation from the AMQP Example for a CF environment

Dev mode

CF Rabbit identifiers the environment it runs in. If no CF environment variables are available then it assumes it's running in local dev mode.

If you want to run it in dev mode then make sure the following environment variables are available:

• DEV_SERVER_NAME (localhost if running a local RMQ)
• DEV_RMQ_URL (full RMQ connection string)

TLS verification is disabled in dev mode

How to use

NewConsumer(queueName string, routingkeys []string, exchange string) (<-chan amqp.Delivery, error) NewPublisher(exchangeName, exchangeType string) (*Publisher, error)

Credits

Thanks go out to creators and maintainers of these modules:

• go-cfenv
• streadway's amqp
• google's uuid

Documentation

Index

• func CreateAndBindQueue(exchangeName, exchangeType, queueName string, routingkeys []string) error
• func UnbindQueue(queueName, key, exchange string) error
• type Session
  • func New() *Session
  • func (s *Session) Close() error

Functions

func CreateAndBindQueue

func CreateAndBindQueue(exchangeName, exchangeType, queueName string, routingkeys []string) error

func UnbindQueue

func UnbindQueue(queueName, key, exchange string) error

Types

type Session

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

func New

func New() *Session

func (*Session) Close

func (s *Session) Close() error

Close will cleanly shutdown the channel and connection.