rbtool

package module

v1.0.4 Latest Latest Go to latest Published: Jul 2, 2020 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/sunp13/rbtool

Links

Open Source Insights

README ¶

rbtool

rabbitmq tool

Documentation ¶

Index ¶

type Logger
- func (l *Logger) Error(format string, v ...interface{})
- func (l *Logger) Info(format string, v ...interface{})
type MyConsumer
- func NewConsumer(URL, qname string) *MyConsumer
type Producer
- func NewProducer(url string) *Producer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Logger ¶

type Logger struct {
	LogSucc      bool // 是否打印成功日志
	LogToConsole bool // 是否打印到控制台
	// contains filtered or unexported fields
}

Logger 生产者日志

func NewConsumerLogger ¶

func NewConsumerLogger(path, alias string) *Logger

NewConsumerLogger 生成新的logger

func NewDefaultLogger ¶

func NewDefaultLogger() *Logger

NewDefaultLogger ...

func NewProducerLogger ¶

func NewProducerLogger(path, alias string) *Logger

NewProducerLogger 生成新的logger

func (*Logger) Error ¶

func (l *Logger) Error(format string, v ...interface{})

Error ...

func (*Logger) Info ¶

func (l *Logger) Info(format string, v ...interface{})

Info ...

type MyConsumer ¶ added in v1.0.0

type MyConsumer struct {

	// 默认参数
	NoAck     bool // only false can use reject and ack
	Exclusive bool
	Requeue   bool
	Argument  amqp.Table
	// contains filtered or unexported fields
}

MyConsumer ...

func NewConsumer ¶ added in v1.0.0

func NewConsumer(URL, qname string) *MyConsumer

NewConsumer ...

func (*MyConsumer) Close ¶ added in v1.0.0

func (c *MyConsumer) Close()

Close ...

func (*MyConsumer) Consume ¶ added in v1.0.0

func (c *MyConsumer) Consume(fn func(msg []byte) error, consumerCount int, prefetchCount int)

Consume ...

func (*MyConsumer) Dial ¶ added in v1.0.0

func (c *MyConsumer) Dial() error

Dial ...

func (*MyConsumer) SetLogger ¶ added in v1.0.1

func (c *MyConsumer) SetLogger(logger *Logger)

SetLogger ...

type Producer ¶

type Producer struct {
	URL string
	// contains filtered or unexported fields
}

Producer 生产者

func NewProducer ¶

func NewProducer(url string) *Producer

NewProducer ...

func (*Producer) Close ¶

func (p *Producer) Close()

Close 关闭

func (*Producer) Dial ¶

func (p *Producer) Dial() error

Dial ... 连接

func (*Producer) Publish ¶

func (p *Producer) Publish(exchange, key string, msg amqp.Publishing) error

Publish 不需要confirm的publish

func (*Producer) PublishConfirmed ¶

func (p *Producer) PublishConfirmed(exchange, key string, msg amqp.Publishing) error

PublishConfirmed ... 发布同步消息-> 等待confirm ack

func (*Producer) SetLogger ¶

func (p *Producer) SetLogger(logger *Logger)

SetLogger 设置logger

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL