amqp

Documentation

Index

• type Client
  • func NewAMQP(conf Config) *Client
  • func (c *Client) CloseResponseConsumer(name string, correlationId string)
  • func (c *Client) RegisterConsumer(name string) chan Message
  • func (c *Client) RegisterProducer(name string) chan Message
  • func (c *Client) RegisterResponseConsumer(name string, correlationId string) chan Message
• type Config
• type Message
• type Queue

Types

type Client

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

Client - Simple AMQP Client wrapper

func NewAMQP

func NewAMQP(conf Config) *Client

NewAMQP - will create a new AMQP Client object

func (*Client) CloseResponseConsumer

func (c *Client) CloseResponseConsumer(name string, correlationId string)

func (*Client) RegisterConsumer

func (c *Client) RegisterConsumer(name string) chan Message

RegisterConsumer - creates a new consumer channel and returns it

func (*Client) RegisterProducer

func (c *Client) RegisterProducer(name string) chan Message

RegisterProducer - creates a new producer channel and returns it

func (*Client) RegisterResponseConsumer

func (c *Client) RegisterResponseConsumer(name string, correlationId string) chan Message

RegisterConsumer - creates a new consumer channel and returns it

type Config

type Config struct {
	Host string `json:"host" toml:"host"`
}

Config - config entry describing a amqp config

type Message

type Message struct {
	Expiration    string
	CorrelationId string
	Payload       string
}

type Queue

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