rabbitmq

Documentation

Overview

Package rabbitmq provides a RabbitMQ broker

Index

• Variables
• func AckOnSuccess() broker.SubscribeOption
• func DeliveryMode(value uint8) broker.PublishOption
• func DurableExchange() broker.Option
• func DurableQueue() broker.SubscribeOption
• func Exchange(e string) broker.Option
• func ExchangeKind(t string) broker.Option
• func ExternalAuth() broker.Option
• func Headers(h map[string]interface{}) broker.SubscribeOption
• func NewBroker(opts ...broker.Option) broker.Broker
• func PrefetchCount(c int) broker.Option
• func PrefetchGlobal() broker.Option
• func QueueArguments(h map[string]interface{}) broker.SubscribeOption
• func RequeueOnError() broker.SubscribeOption
• func SubscribeContext(ctx context.Context) broker.SubscribeOption
• type ExternalAuthentication
  • func (auth *ExternalAuthentication) Mechanism() string
  • func (auth *ExternalAuthentication) Response() string

Variables

var (
	DefaultExchange = exchange{
					// contains filtered or unexported fields
	}
	DefaultRabbitURL      = "amqp://guest:guest@127.0.0.1:5672"
	DefaultPrefetchCount  = 0
	DefaultPrefetchGlobal = false
	DefaultRequeueOnError = false
)

Functions

func AckOnSuccess

func AckOnSuccess() broker.SubscribeOption

AckOnSuccess will automatically acknowledge messages when no error is returned

func DeliveryMode

func DeliveryMode(value uint8) broker.PublishOption

DeliveryMode sets a delivery mode for publishing

func DurableExchange

func DurableExchange() broker.Option

DurableExchange is an option to set the Exchange to be durable

func DurableQueue

func DurableQueue() broker.SubscribeOption

DurableQueue creates a durable queue when subscribing.

func Exchange

func Exchange(e string) broker.Option

Exchange is an option to set the Exchange

func ExchangeKind

func ExchangeKind(t string) broker.Option

func ExternalAuth

func ExternalAuth() broker.Option

func Headers

func Headers(h map[string]interface{}) broker.SubscribeOption

Headers adds headers used by the headers exchange

func NewBroker

func NewBroker(opts ...broker.Option) broker.Broker

func PrefetchCount

func PrefetchCount(c int) broker.Option

PrefetchCount ...

func PrefetchGlobal

func PrefetchGlobal() broker.Option

PrefetchGlobal creates a durable queue when subscribing.

func QueueArguments

func QueueArguments(h map[string]interface{}) broker.SubscribeOption

QueueArguments sets arguments for queue creation

func RequeueOnError

func RequeueOnError() broker.SubscribeOption

RequeueOnError calls Nack(muliple:false, requeue:true) on amqp delivery when handler returns error

func SubscribeContext

func SubscribeContext(ctx context.Context) broker.SubscribeOption

SubscribeContext set the context for broker.SubscribeOption

Types

type ExternalAuthentication

type ExternalAuthentication struct {
}

func (*ExternalAuthentication) Mechanism

func (auth *ExternalAuthentication) Mechanism() string

func (*ExternalAuthentication) Response

func (auth *ExternalAuthentication) Response() string