rabbit

README

go-amqp

Go package that provides easy use of amqp RabbitMQ client

Documentation

Index

• type AMQPClient
  • func (a *AMQPClient) CreateChannel() error
  • func (a *AMQPClient) GetQueueName() string
  • func (a *AMQPClient) SendMessage(exchange, routingKey string, message interface{}) error
  • func (a *AMQPClient) SetupDispatcher(exchange, exchangeType string, isDurable, autoDelete bool) error
  • func (a *AMQPClient) SetupQueues(queueName string, queueIsDurable, autoDelete bool, routingKeys []string, ...) error
  • func (a *AMQPClient) StartConnection(username, password, host string, port int) error
  • func (a *AMQPClient) StartReceiver(queueName string, isDurable, autoDelete bool, routingKeys []string, ...) (<-chan amqp.Delivery, error)

Examples

• AMQPClient.StartReceiver

Types

type AMQPClient

type AMQPClient struct {
	Connection *amqp.Connection
	Channel    *amqp.Channel
	Reception  struct {
		Queue amqp.Queue
	}
	Dispatch struct{}
}

AMQPClient contains the basic objects for a AMQ connection

func (*AMQPClient) CreateChannel

func (a *AMQPClient) CreateChannel() error

AMQPClient_CreateChannel creates a channel and saves it in struct

func (*AMQPClient) GetQueueName

func (a *AMQPClient) GetQueueName() string

AMQPClient_GetQueueName return the queue name for a receiver

func (*AMQPClient) SendMessage

func (a *AMQPClient) SendMessage(exchange, routingKey string, message interface{}) error

AMQPClient_SendMessage Deliver the message to the specified exchange, if exchange not created this will throw an error

func (*AMQPClient) SetupDispatcher

func (a *AMQPClient) SetupDispatcher(exchange, exchangeType string, isDurable, autoDelete bool) error

AMQPClient_SetupDispatcher Declares the exchanges to be used to deliver messages

func (*AMQPClient) SetupQueues

func (a *AMQPClient) SetupQueues(queueName string, queueIsDurable, autoDelete bool, routingKeys []string, exchange string) error

AMQPClient_SetupQueues Declares and binds a queue to an exchange

func (*AMQPClient) StartConnection

func (a *AMQPClient) StartConnection(username, password, host string, port int) error

AMQPClient_StartConnection Starts the connection with rabbitMQ server. Dials up and creates a channel

func (*AMQPClient) StartReceiver

func (a *AMQPClient) StartReceiver(queueName string, isDurable, autoDelete bool, routingKeys []string, exchanges interface{}, consumerTag string) (<-chan amqp.Delivery, error)

AMQPClient_StartReceiver Starts a rabbit MQ receiver with the passed configuration, returns a channel that will receive the messages, along with the connection and channel instance

Example

Checks the exchange used actually exist on a server

go runDispatching()
client, err := getConn()
if err != nil {
	log.Fatalf("Failure getting client to connect: %s", err)
}
messageChannel, err := client.StartReceiver(
	"client_test",
	false,
	false,
	[]string{""},
	"test",
)
if err != nil {
	log.Fatalf("Failure starting receive: %s", err)
}
c := <-messageChannel
fmt.Println(c.Exchange)

Output:

test