rabbitmq

Documentation

Index

• Constants
• func CreateConsumer(entry config.RabbitEntry, rabbitConnector connector.RabbitConnector) consumer.Client
• type Consumer
  • func (c Consumer) Name() string
  • func (c Consumer) Start(forwarder forwarder.Client, check chan bool, stop chan bool) error

Constants

const (
	// Type consumer type
	Type = "RabbitMQ"

	// ReconnectRabbitMQInterval time to reconnect
	ReconnectRabbitMQInterval = 10
)

Functions

func CreateConsumer

func CreateConsumer(entry config.RabbitEntry, rabbitConnector connector.RabbitConnector) consumer.Client

CreateConsumer creates consumer from string map

Types

type Consumer

type Consumer struct {
	ConnectionURL   string
	ExchangeName    string
	QueueName       string
	RoutingKeys     []string
	RabbitConnector connector.RabbitConnector
	// contains filtered or unexported fields
}

Consumer implementation or RabbitMQ consumer

func (Consumer) Name

func (c Consumer) Name() string

Name consumer name

func (Consumer) Start

func (c Consumer) Start(forwarder forwarder.Client, check chan bool, stop chan bool) error

Start start consuming messages from Rabbit queue