consume

Documentation

Index

• Variables
• type ArgsDecl
  • func (a ArgsDecl) Defaults() ErrorChan
  • func (a ArgsDecl) WithErrorChan(errorChan chan error) ErrorChan
• type AutoAckDecl
  • func (a AutoAckDecl) Defaults() ErrorChan
  • func (a AutoAckDecl) WithDefaultExclusive() ExclusiveDecl
  • func (a AutoAckDecl) WithExclusive(exclusive bool) ExclusiveDecl
• type ConsumerDecl
  • func (d ConsumerDecl) Defaults() ErrorChan
  • func (d ConsumerDecl) WithAutoAck(autoAck bool) AutoAckDecl
  • func (d ConsumerDecl) WithDefaultAutoAck() AutoAckDecl
• type DeliveryChan
  • func (d DeliveryChan) Defaults() ErrorChan
  • func (d DeliveryChan) WithConsumer(consumer string) ConsumerDecl
  • func (d DeliveryChan) WithDefaultConsumer() ConsumerDecl
• type ErrorChan
  • func (e ErrorChan) Build(ch *chamqp.Channel)
  • func (e ErrorChan) BuildSpec() chamqp.ConsumeSpec
• type ExclusiveDecl
  • func (e ExclusiveDecl) Defaults() ErrorChan
  • func (e ExclusiveDecl) WithDefaultNoLocal() NoLocalDecl
  • func (e ExclusiveDecl) WithNoLocal(noLocal bool) NoLocalDecl
• type NoLocalDecl
  • func (n NoLocalDecl) Defaults() ErrorChan
  • func (n NoLocalDecl) WithNoWait(noWait bool) NoWaitDecl
• type NoWaitDecl
  • func (n NoWaitDecl) Defaults() ErrorChan
  • func (n NoWaitDecl) WithArgs(args amqp.Table) ArgsDecl
• type QueueDecl
  • func Consume(queueName string) QueueDecl
  • func (q QueueDecl) WithDeliveryChan(deliveryChan chan amqp.Delivery) DeliveryChan

Variables

var Defaults = chamqp.ConsumeSpec{
	Queue:        "",
	DeliveryChan: nil,

	Consumer:  "",
	AutoAck:   true,
	Exclusive: false,
	NoLocal:   false,
	NoWait:    false,
	Args:      nil,
	ErrorChan: nil,
}

Types

type ArgsDecl

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

func (ArgsDecl) Defaults

func (a ArgsDecl) Defaults() ErrorChan

func (ArgsDecl) WithErrorChan

func (a ArgsDecl) WithErrorChan(errorChan chan error) ErrorChan

type AutoAckDecl

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

func (AutoAckDecl) Defaults

func (a AutoAckDecl) Defaults() ErrorChan

func (AutoAckDecl) WithDefaultExclusive

func (a AutoAckDecl) WithDefaultExclusive() ExclusiveDecl

func (AutoAckDecl) WithExclusive

func (a AutoAckDecl) WithExclusive(exclusive bool) ExclusiveDecl

type ConsumerDecl

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

func (ConsumerDecl) Defaults

func (d ConsumerDecl) Defaults() ErrorChan

func (ConsumerDecl) WithAutoAck

func (d ConsumerDecl) WithAutoAck(autoAck bool) AutoAckDecl

func (ConsumerDecl) WithDefaultAutoAck

func (d ConsumerDecl) WithDefaultAutoAck() AutoAckDecl

type DeliveryChan

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

func (DeliveryChan) Defaults

func (d DeliveryChan) Defaults() ErrorChan

func (DeliveryChan) WithConsumer

func (d DeliveryChan) WithConsumer(consumer string) ConsumerDecl

func (DeliveryChan) WithDefaultConsumer

func (d DeliveryChan) WithDefaultConsumer() ConsumerDecl

type ErrorChan

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

func (ErrorChan) Build

func (e ErrorChan) Build(ch *chamqp.Channel)

func (ErrorChan) BuildSpec

func (e ErrorChan) BuildSpec() chamqp.ConsumeSpec

type ExclusiveDecl

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

func (ExclusiveDecl) Defaults

func (e ExclusiveDecl) Defaults() ErrorChan

func (ExclusiveDecl) WithDefaultNoLocal

func (e ExclusiveDecl) WithDefaultNoLocal() NoLocalDecl

func (ExclusiveDecl) WithNoLocal

func (e ExclusiveDecl) WithNoLocal(noLocal bool) NoLocalDecl

type NoLocalDecl

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

func (NoLocalDecl) Defaults

func (n NoLocalDecl) Defaults() ErrorChan

func (NoLocalDecl) WithNoWait

func (n NoLocalDecl) WithNoWait(noWait bool) NoWaitDecl

type NoWaitDecl

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

func (NoWaitDecl) Defaults

func (n NoWaitDecl) Defaults() ErrorChan

func (NoWaitDecl) WithArgs

func (n NoWaitDecl) WithArgs(args amqp.Table) ArgsDecl

type QueueDecl

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

func Consume

func Consume(queueName string) QueueDecl

func (QueueDecl) WithDeliveryChan

func (q QueueDecl) WithDeliveryChan(deliveryChan chan amqp.Delivery) DeliveryChan