rabbitmqlib

Documentation

Index

• type Channel
• type Connection
  • func (c *Connection) CloseChannel(channel *Channel)
  • func (c *Connection) Connect(mqAddress string)
  • func (c *Connection) GetChannel() (*Channel, error)
  • func (c *Connection) GetChannelCount() int
• type RabbitMqProxy
  • func (r *RabbitMqProxy) Dial(address string)
  • func (r *RabbitMqProxy) ReceiveFanoutMessage(subscribe *Subscribe) error
  • func (r *RabbitMqProxy) ReceiveQueryMessage(queueName string, messageReceived func(<-chan amqp.Delivery)) error
  • func (r *RabbitMqProxy) ReceiveRouterMessage(exchangeName string, routingKeys ...string) (<-chan amqp.Delivery, error)
  • func (r *RabbitMqProxy) ReceiveTopicMessage(subscribe *Subscribe) error
  • func (r *RabbitMqProxy) SendFanoutMessage(exchangeName string, datas []byte) error
  • func (r *RabbitMqProxy) SendQueryMessage(queueName string, datas []byte) error
  • func (r *RabbitMqProxy) SendRouterMessage(exchangeName string, routingKey string, datas []byte) error
  • func (r *RabbitMqProxy) SendTopicMessage(exchangeName string, routingKey string, datas []byte) error
• type Subscribe

Types

type Channel

type Channel struct {
	IsUsed   bool
	CH       *amqp.Channel
	Identify string
}

Channel Channel

type Connection

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

Connection Connection

func (*Connection) CloseChannel

func (c *Connection) CloseChannel(channel *Channel)

CloseChannel CloseChannel

func (*Connection) Connect

func (c *Connection) Connect(mqAddress string)

Connect Connect

func (*Connection) GetChannel

func (c *Connection) GetChannel() (*Channel, error)

GetChannel GetChannel

func (*Connection) GetChannelCount

func (c *Connection) GetChannelCount() int

GetChannelCount 获取Channel数量

type RabbitMqProxy

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

RabbitMqProxy RabbitMqProxy

func (*RabbitMqProxy) Dial

func (r *RabbitMqProxy) Dial(address string)

address amqp://user:pass@hostName:port/vhost Dial connect rabbitmq

func (*RabbitMqProxy) ReceiveFanoutMessage

func (r *RabbitMqProxy) ReceiveFanoutMessage(subscribe *Subscribe) error

ReceiveFanoutMessage receive p/s message router

func (*RabbitMqProxy) ReceiveQueryMessage

func (r *RabbitMqProxy) ReceiveQueryMessage(queueName string, messageReceived func(<-chan amqp.Delivery)) error

ReceiveQueryMessage 获取Query

func (*RabbitMqProxy) ReceiveRouterMessage

func (r *RabbitMqProxy) ReceiveRouterMessage(exchangeName string, routingKeys ...string) (<-chan amqp.Delivery, error)

ReceiveRouterMessage receive p/s message router

func (*RabbitMqProxy) ReceiveTopicMessage

func (r *RabbitMqProxy) ReceiveTopicMessage(subscribe *Subscribe) error

ReceiveTopicMessage ReceiveTopicMessage

func (*RabbitMqProxy) SendFanoutMessage

func (r *RabbitMqProxy) SendFanoutMessage(exchangeName string, datas []byte) error

SendFanoutMessage send p/s message router

func (*RabbitMqProxy) SendQueryMessage

func (r *RabbitMqProxy) SendQueryMessage(queueName string, datas []byte) error

SendQueryMessage 发送Query

func (*RabbitMqProxy) SendRouterMessage

func (r *RabbitMqProxy) SendRouterMessage(exchangeName string, routingKey string, datas []byte) error

SendRouterMessage send p/s message router

func (*RabbitMqProxy) SendTopicMessage

func (r *RabbitMqProxy) SendTopicMessage(exchangeName string, routingKey string, datas []byte) error

SendTopicMessage send p/s message router

type Subscribe

type Subscribe struct {
	ExchangeName    string
	QueueName       string
	RoutingKey      string
	MessageReceived func([]byte)
}

Subscribe Subscribe