rabbit

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 10, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ConnRabbitErr       ConnRabbitError
	NewChannelErr       NewChannelError
	NewQueueErr         NewQueueError
	QueueNotExistErr    QueueNotExistError
	PublishMessageErr   PublishMessageError
	RegisterConsumerErr RegisterConsumerError
)

Functions

This section is empty.

Types

type ConnRabbitError 

type ConnRabbitError struct{ myError.MyError }

func (*ConnRabbitError) Error 

func (my *ConnRabbitError) Error() string

func (*ConnRabbitError) Is 

func (my *ConnRabbitError) Is(target error) bool

func (*ConnRabbitError) New 

func (*ConnRabbitError) New(msg string) myError.IMyError

func (*ConnRabbitError) Panic 

func (*ConnRabbitError) Panic() myError.IMyError

func (*ConnRabbitError) Wrap 

func (*ConnRabbitError) Wrap(err error) myError.IMyError

type Consumer 

type Consumer struct {
	// contains filtered or unexported fields
}
var ConsumerApp Consumer

func (*Consumer) Error 

func (my *Consumer) Error() error

Error 获取错误信息

func (*Consumer) Go 

func (my *Consumer) Go() <-chan amqp.Delivery

func (*Consumer) New 

func (*Consumer) New(
	ch *amqp.Channel,
	queue amqp.Queue,
	consumer string,
	parseFn func(message []byte) error,
) *Consumer

func (*Consumer) Start 

func (my *Consumer) Start() *Consumer

Start 监听：开始

func (*Consumer) Stop 

func (my *Consumer) Stop() *Consumer

Stop 停止监听

type Message 

type Message struct {
	MsgId   string `json:"msgId" yaml:"msgId"`
	Content []byte `json:"content" yaml:"content"`
	// contains filtered or unexported fields
}
var (
	MessageApp Message
)

func (*Message) New 

func (*Message) New(message []byte) *Message

New 实例化：创建消息

func (*Message) Parse 

func (*Message) Parse(prototypeMessage []byte) *Message

Parse 实例化：通过原始消息解析

func (*Message) ToJson 

func (my *Message) ToJson() []byte

ToJson 序列化：json

type NewChannelError 

type NewChannelError struct{ myError.MyError }

func (*NewChannelError) Error 

func (my *NewChannelError) Error() string

func (*NewChannelError) Is 

func (my *NewChannelError) Is(target error) bool

func (*NewChannelError) New 

func (*NewChannelError) New(msg string) myError.IMyError

func (*NewChannelError) Panic 

func (*NewChannelError) Panic() myError.IMyError

func (*NewChannelError) Wrap 

func (*NewChannelError) Wrap(err error) myError.IMyError

type NewQueueError 

type NewQueueError struct{ myError.MyError }

func (*NewQueueError) Error 

func (my *NewQueueError) Error() string

func (*NewQueueError) Is 

func (my *NewQueueError) Is(target error) bool

func (*NewQueueError) New 

func (*NewQueueError) New(msg string) myError.IMyError

func (*NewQueueError) Panic 

func (*NewQueueError) Panic() myError.IMyError

func (*NewQueueError) Wrap 

func (*NewQueueError) Wrap(err error) myError.IMyError

type Pool 

type Pool struct {
	// contains filtered or unexported fields
}
var (
	PoolApp Pool
)

func (*Pool) Get 

func (*Pool) Get(key string) *Rabbit

Get 获取链接

func (*Pool) Once 

func (*Pool) Once() *Pool

Once 单例化：rabbit-mq连接池

func (*Pool) Set 

func (*Pool) Set(key string, value *Rabbit) *Pool

Set 添加链接

type PublishMessageError 

type PublishMessageError struct{ myError.MyError }

func (*PublishMessageError) Error 

func (my *PublishMessageError) Error() string

func (*PublishMessageError) Is 

func (my *PublishMessageError) Is(target error) bool

func (*PublishMessageError) New 

func (*PublishMessageError) New(msg string) myError.IMyError

func (*PublishMessageError) Panic 

func (*PublishMessageError) Panic() myError.IMyError

func (*PublishMessageError) Wrap 

func (*PublishMessageError) Wrap(err error) myError.IMyError

type QueueNotExistError 

type QueueNotExistError struct{ myError.MyError }

func (*QueueNotExistError) Error 

func (my *QueueNotExistError) Error() string

func (*QueueNotExistError) Is 

func (my *QueueNotExistError) Is(target error) bool

func (*QueueNotExistError) New 

func (*QueueNotExistError) New(msg string) myError.IMyError

func (*QueueNotExistError) Panic 

func (*QueueNotExistError) Panic() myError.IMyError

func (*QueueNotExistError) Wrap 

func (*QueueNotExistError) Wrap(err error) myError.IMyError

type Rabbit 

type Rabbit struct {
	// contains filtered or unexported fields
}
var RabbitApp Rabbit

func (*Rabbit) Close 

func (my *Rabbit) Close() error

Close 关闭链接

func (*Rabbit) CloseChannel 

func (my *Rabbit) CloseChannel() *Rabbit

CloseChannel 关闭频道

func (*Rabbit) Consume 

func (my *Rabbit) Consume(queueName, consumer string, parseFn func(prototypeMessage []byte) error) *Consumer

Consume 消费消息

func (*Rabbit) Error 

func (my *Rabbit) Error() error

Error 获取错误

func (*Rabbit) GetConn 

func (my *Rabbit) GetConn() *amqp.Connection

GetConn 获取链接

func (*Rabbit) New 

func (*Rabbit) New(
	username,
	password,
	host,
	port,
	virtualHost string,
) *Rabbit

New 创建一个 Rabbit 实例

func (*Rabbit) NewChannel 

func (my *Rabbit) NewChannel() *Rabbit

NewChannel 创建频道

func (*Rabbit) NewQueue 

func (my *Rabbit) NewQueue(queueName string) *Rabbit

NewQueue 创建队列

func (*Rabbit) Publish 

func (my *Rabbit) Publish(queueName string, body string) *Rabbit

Publish 生产消息

type RegisterConsumerError 

type RegisterConsumerError struct{ myError.MyError }

func (*RegisterConsumerError) Error 

func (my *RegisterConsumerError) Error() string

func (*RegisterConsumerError) Is 

func (my *RegisterConsumerError) Is(target error) bool

func (*RegisterConsumerError) New 

func (*RegisterConsumerError) New(msg string) myError.IMyError

func (*RegisterConsumerError) Panic 

func (*RegisterConsumerError) Panic() myError.IMyError

func (*RegisterConsumerError) Wrap 

func (*RegisterConsumerError) Wrap(err error) myError.IMyError

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.