queue

Documentation

Overview

cSpell:ignore vhost

Index

• type AMQPServerConnection
  • func (c *AMQPServerConnection) CloseConnection() error
  • func (c *AMQPServerConnection) DefaultQueue() string
  • func (c *AMQPServerConnection) DefaultQueuePublishJSON(channel string, msg interface{}) error
  • func (c *AMQPServerConnection) DefaultQueueRetrieve(channel string) (*amqp.Delivery, error)
  • func (c *AMQPServerConnection) HasConnection() bool
  • func (c *AMQPServerConnection) IsChannelOpen(name string) bool
  • func (c *AMQPServerConnection) OpenChannel(name string) (*amqp.Channel, error)
  • func (c *AMQPServerConnection) OpenConnection() (*amqp.Connection, error)
  • func (c *AMQPServerConnection) OpenQueueChannel(name string, queue string, create bool) (*amqp.Channel, error)
  • func (c *AMQPServerConnection) Prefix() string
  • func (c *AMQPServerConnection) QueuePublishJSON(channel string, queue string, msg interface{}) error
  • func (c *AMQPServerConnection) QueuePublishString(channel string, queue string, msg string) error
  • func (c *AMQPServerConnection) QueueRetrieve(channel string, queue string) (*amqp.Delivery, error)
  • func (c *AMQPServerConnection) ResetConnection() (*amqp.Connection, error)
  • func (c *AMQPServerConnection) SetConnection(s []shared.AMQPConnection) error
  • func (c *AMQPServerConnection) SetDefaultQueue(name string) error
  • func (c *AMQPServerConnection) SetPrefix(p string) error

Types

type AMQPServerConnection

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

func (*AMQPServerConnection) CloseConnection

func (c *AMQPServerConnection) CloseConnection() error

func (*AMQPServerConnection) DefaultQueue

func (c *AMQPServerConnection) DefaultQueue() string

func (*AMQPServerConnection) DefaultQueuePublishJSON

func (c *AMQPServerConnection) DefaultQueuePublishJSON(channel string, msg interface{}) error

func (*AMQPServerConnection) DefaultQueueRetrieve

func (c *AMQPServerConnection) DefaultQueueRetrieve(channel string) (*amqp.Delivery, error)

func (*AMQPServerConnection) HasConnection

func (c *AMQPServerConnection) HasConnection() bool

func (*AMQPServerConnection) IsChannelOpen

func (c *AMQPServerConnection) IsChannelOpen(name string) bool

func (*AMQPServerConnection) OpenChannel

func (c *AMQPServerConnection) OpenChannel(name string) (*amqp.Channel, error)

func (*AMQPServerConnection) OpenConnection

func (c *AMQPServerConnection) OpenConnection() (*amqp.Connection, error)

func (*AMQPServerConnection) OpenQueueChannel

func (c *AMQPServerConnection) OpenQueueChannel(name string, queue string, create bool) (*amqp.Channel, error)

func (*AMQPServerConnection) Prefix

func (c *AMQPServerConnection) Prefix() string

func (*AMQPServerConnection) QueuePublishJSON

func (c *AMQPServerConnection) QueuePublishJSON(channel string, queue string, msg interface{}) error

func (*AMQPServerConnection) QueuePublishString

func (c *AMQPServerConnection) QueuePublishString(channel string, queue string, msg string) error

func (*AMQPServerConnection) QueueRetrieve

func (c *AMQPServerConnection) QueueRetrieve(channel string, queue string) (*amqp.Delivery, error)

func (*AMQPServerConnection) ResetConnection

func (c *AMQPServerConnection) ResetConnection() (*amqp.Connection, error)

func (*AMQPServerConnection) SetConnection

func (c *AMQPServerConnection) SetConnection(s []shared.AMQPConnection) error

func (*AMQPServerConnection) SetDefaultQueue

func (c *AMQPServerConnection) SetDefaultQueue(name string) error

func (*AMQPServerConnection) SetPrefix

func (c *AMQPServerConnection) SetPrefix(p string) error