amqp

README

Atomizer AMQP Conductor Implementation

AMPQ conductor implementation for Atomizer

Documentation

Index

• Constants
• type Conductor
  • func Connect(ctx context.Context, connectionstring, inqueue string) (c Conductor, err error)

Constants

const (
	// DEFAULTADDRESS is the address to connect to rabbitmq
	DEFAULTADDRESS string = "amqp://guest:guest@localhost:5672/"
)

Types

type Conductor

type Conductor interface {
	engine.Conductor
	Events(buffer int) <-chan interface{}
	Errors(buffer int) <-chan error
}

func Connect

func Connect(
	ctx context.Context,
	connectionstring,
	inqueue string,
) (c Conductor, err error)

Connect uses the connection string that is passed in to initialize the rabbitmq conductor