Documentation
¶
Index ¶
- Variables
- func BindRoutingKey(api, user, passwd, vhost, name, exchange, key string) error
- func CreateQueue(api, user, passwd, vhost, name string) error
- func FakeIdDecode(str string) int64
- func FakeIdEncode(number int64) string
- func NewReceiveConsumer(url string) (*receiveConsumer, error)
- func RegisterQueue(api, user, passwd, vhost, name, exchange, key string) error
- type ReceiveTool
Constants ¶
This section is empty.
Variables ¶
View Source
var Logger *zap.Logger
Functions ¶
func BindRoutingKey ¶
func CreateQueue ¶
func FakeIdDecode ¶
func FakeIdEncode ¶
func NewReceiveConsumer ¶
func RegisterQueue ¶
Types ¶
type ReceiveTool ¶
type ReceiveTool struct {
// contains filtered or unexported fields
}
func (*ReceiveTool) Publish ¶
func (c *ReceiveTool) Publish(route, msg string)
Source Files
Click to show internal directories.
Click to hide internal directories.