amqp

Documentation

Overview

Package amqp is the AMQP implementation of an event stream.

Index

• Constants
• type AMQP
  • func NewAMQP(conn *amqp.Connection) *AMQP
  • func (r *AMQP) Send(ctx context.Context, evt *outboxer.OutboxMessage) error

Examples

• NewAMQP

Constants

const (

	// ExchangeNameOption is the exchange name option
	ExchangeNameOption = "exchange.name"

	// ExchangeTypeOption is the exchange type option
	ExchangeTypeOption = "exchange.type"

	// ExchangeDurable is the exchange durable option
	ExchangeDurable = "exchange.durable"

	// ExchangeAutoDelete is the exchange auto delete option
	ExchangeAutoDelete = "exchange.auto_delete"

	// ExchangeInternal is the exchange internal option
	ExchangeInternal = "exchange.internal"

	// ExchangeNoWait is the exchange no wait option
	ExchangeNoWait = "exchange.no_wait"

	// RoutingKeyOption is the routing key option
	RoutingKeyOption = "routing_key"
)

Types

type AMQP

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

AMQP is the wrapper for the AMQP library

func NewAMQP

func NewAMQP(conn *amqp.Connection) *AMQP

NewAMQP creates a new instance of AMQP

Example

package main

import (
	"context"
	"fmt"
	"os"

	"github.com/italolelis/outboxer"
	amqpOut "github.com/italolelis/outboxer/amqp"
	"github.com/streadway/amqp"
)

func main() {
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()

	conn, err := amqp.Dial(os.Getenv("ES_DSN"))
	if err != nil {
		fmt.Printf("failed to connect to amqp: %s", err)
		return
	}
	defer conn.Close()

	es := amqpOut.NewAMQP(conn)

	// this is done internally by outboxer
	if err := es.Send(ctx, &outboxer.OutboxMessage{
		Payload: []byte("test payload"),
		Options: map[string]interface{}{
			amqpOut.ExchangeNameOption: "test",
			amqpOut.ExchangeTypeOption: "topic",
			amqpOut.RoutingKeyOption:   "test.send",
		},
	}); err != nil {
		fmt.Printf("an error was not expected: %s", err)
		return
	}
}

func (*AMQP) Send

func (r *AMQP) Send(ctx context.Context, evt *outboxer.OutboxMessage) error

Send sends the message to the event stream