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 DurableMessageContext(ctx context.Context) context.Context
• func DurableQueue() broker.SubscribeOption
• func Exchange(e 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 ServerAckOnSuccess() server.SubscriberOption
• func ServerDurableQueue() server.SubscriberOption
• 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 DurableMessageContext

func DurableMessageContext(ctx context.Context) context.Context

DurableMessageContext create new context with metadata for durable message sending

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 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 ServerAckOnSuccess

func ServerAckOnSuccess() server.SubscriberOption

ServerAckOnSuccess support "manual ack" on success

func ServerDurableQueue

func ServerDurableQueue() server.SubscriberOption

ServerDurableQueue provide durable queue option for micro.RegisterSubscriber

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