rabbit

Documentation

Index

• func UpdateRabbitConnection(key string, connect *ConnectionStruct)
• type ConnectionStruct
  • func GetRabbitConnection(key string) (*ConnectionStruct, bool)
  • func OpenRabbitConnection(key string, user string, pass string, host string, port string) (*ConnectionStruct, error)
  • func (connectionItem *ConnectionStruct) CloseAll()
  • func (connectionItem *ConnectionStruct) Listen(queueName string, exchangeName string, callback func(body []byte) []byte)
  • func (connectionItem *ConnectionStruct) SendMessageListToExchange(exchangeName string, messageList [][]byte)
  • func (connectionItem *ConnectionStruct) SendMessageListToQueue(queueName string, messageList [][]byte)
  • func (connectionItem *ConnectionStruct) SendMessageToQueue(queueName string, message []byte)

Functions

func UpdateRabbitConnection

func UpdateRabbitConnection(key string, connect *ConnectionStruct)

получаем конфигурацию main

Types

type ConnectionStruct

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

структура соединения

func GetRabbitConnection

func GetRabbitConnection(key string) (*ConnectionStruct, bool)

получить соединение rabbit

func OpenRabbitConnection

func OpenRabbitConnection(key string, user string, pass string, host string, port string) (*ConnectionStruct, error)

создаем объект соединения

func (*ConnectionStruct) CloseAll

func (connectionItem *ConnectionStruct) CloseAll()

закрываем все соединения

func (*ConnectionStruct) Listen

func (connectionItem *ConnectionStruct) Listen(queueName string, exchangeName string, callback func(body []byte) []byte)

слушаем

func (*ConnectionStruct) SendMessageListToExchange

func (connectionItem *ConnectionStruct) SendMessageListToExchange(exchangeName string, messageList [][]byte)

отправляем сообщения в очередь

func (*ConnectionStruct) SendMessageListToQueue

func (connectionItem *ConnectionStruct) SendMessageListToQueue(queueName string, messageList [][]byte)

SendMessageListToQueue отправляем сообщения в очередь

func (*ConnectionStruct) SendMessageToQueue

func (connectionItem *ConnectionStruct) SendMessageToQueue(queueName string, message []byte)

отправляем сообщение в очередь