punter

README

punter

This library provides a "batteries included" consumer for AMQP topics. The aim is to make it as simple as possible to build small AMQP driven consumers.

Sponsor

This project was made possible by Ninja Blocks.

License

This code is Copyright (c) 2014 Mark Wolfe and licenced under the MIT licence. All rights not explicitly granted in the MIT license are reserved. See the included LICENSE.md file for more details.

Documentation

Index

• Constants
• type Config
• type Consumer
  • func NewConsumer(config *Config, ctag string, msgHandler MsgHander) (*Consumer, error)
  • func (c *Consumer) Shutdown() error
• type MsgHander

Constants

const Version = "1.2.0"

Types

type Config

type Config struct {
	AmqpURI      string
	Exchange     string
	ExchangeType string
	QueueName    string
	Key          string
	MessageTTL   int32 // How long to retain messages in the queue
	Durable      bool  // Queue durable?
}

Config is the settings for the consumer

type Consumer

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

Consumer holds state for the AMQP consumer

func NewConsumer

func NewConsumer(config *Config, ctag string, msgHandler MsgHander) (*Consumer, error)

NewConsumer create and configure a new consumer, this also triggers a connection to AMQP server

func (*Consumer) Shutdown

func (c *Consumer) Shutdown() error

Shutdown enables cleanup of AMQP connection

type MsgHander

type MsgHander func(deliveries <-chan amqp.Delivery, done chan error)

MsgHander function which is supplied to handle delivers.