Documentation
¶
Index ¶
- Variables
- func Connect(userName, password, address string)
- func Producer(queueName string, request []byte) error
- func Publish(exchangeName string, request []byte) error
- func RPCClient(queueName string, request []byte) (reply []byte, err error)
- func RPCServer(queueName string, f func([]byte) []byte)
- func Receive(ch *amqp.Channel, QueueName string) (<-chan amqp.Delivery, error)
- func RouteConsume(ch *amqp.Channel, exchangeName, key string) (<-chan amqp.Delivery, error)
- func RoutePublish(exchangeName, key string, request []byte) error
- func Send(QueueName string, request []byte) error
- func Subscribe(exchangeName string) (<-chan amqp.Delivery, error)
- func TopicEmit(exchangeName, key string, request []byte) error
- func TopicReceive(exchangeName string, keys ...string) (<-chan amqp.Delivery, error)
- func Worker(queueName string) (<-chan amqp.Delivery, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var Conn *amqp.Connection
Functions ¶
func RouteConsume ¶
一个线程用一个channel，多个go程共用一个channel
func TopicReceive ¶ added in v0.4.0
keys 绑定多个路由 key支持以下规则 *（星号）：可以（只能）匹配一个单词 #（井号）：可以匹配多个单词（或者零个）
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.