Documentation
¶
Index ¶
- func DefineQueue(channel *amqp.Channel, queueName string) (amqp.Queue, error)
- func HandleReceivedIndices(subscriber <-chan amqp.Delivery, indicesChannel chan []string)
- func OpenChannel(connection *amqp.Connection) (*amqp.Channel, error)
- func OpenConnection() (*amqp.Connection, error)
- func OpenSubscriber(channel *amqp.Channel, queueName string) (<-chan amqp.Delivery, error)
- func PublishIndices(channel *amqp.Channel, queueName string, result *exchange.ExchangesResult) error
- type ChannelError
- type ConnectionError
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func HandleReceivedIndices ¶
func OpenChannel ¶
func OpenChannel(connection *amqp.Connection) (*amqp.Channel, error)
func OpenConnection ¶
func OpenConnection() (*amqp.Connection, error)
func OpenSubscriber ¶
func PublishIndices ¶
Types ¶
type ChannelError ¶
type ChannelError struct {
// contains filtered or unexported fields
}
func (*ChannelError) Error ¶
func (channelError *ChannelError) Error() string
type ConnectionError ¶
type ConnectionError struct {
// contains filtered or unexported fields
}
func (*ConnectionError) Error ¶
func (connError *ConnectionError) Error() string
Source Files
Click to show internal directories.
Click to hide internal directories.