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 ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files