Documentation ¶
Index ¶
- Constants
- func AckFunc(m amqp.Delivery) func() error
- func ConnString(params *gq.ConnParam) string
- func Queue(c *Channel, name string) (q *amqp.Queue, err error)
- type Channel
- func (c *Channel) Channel() (ch *amqp.Channel, err error)
- func (c *Channel) Close() (err error)
- func (c *Channel) Consume(queue string, noAck bool) (out chan gq.Message, err error)
- func (c *Channel) Count(queue string) (count int, err error)
- func (c *Channel) Delete(queue string, identifier string) (err error)
- func (c *Channel) GetOne(queue string, noAck bool) (msg gq.Message, err error)
- func (c *Channel) Post(queue string, msg gq.Message, delay time.Duration) (err error)
Constants ¶
View Source
const DelayExchange = "gq-delay"
View Source
const StandardExchange = "gq-immediate"
View Source
const UnsupportedCallErr = "Call unimplemented or not supported by RabbitMQ"
Variables ¶
This section is empty.
Functions ¶
func ConnString ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.