Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Channel ¶
func (*Channel) ExchangeDeclare ¶
type Rabbit ¶
type Rabbit struct {
// contains filtered or unexported fields
}
type RabbitFull ¶
type RabbitFull struct {
// contains filtered or unexported fields
}
func NewRabbitFull ¶
func NewRabbitFull(url string) *RabbitFull
func (*RabbitFull) SimplyPublish ¶
func (p *RabbitFull) SimplyPublish(queue string, body []byte) error
发送也是长连接,短连接在连接上非常耗时
func (*RabbitFull) SimplyReceive ¶
func (p *RabbitFull) SimplyReceive(exchange string, exchangeKind string, queue string, h Handler) error
接收消息, 如果断线会在5s后重试
Click to show internal directories.
Click to hide internal directories.