rabbitmqlib

package
v0.0.0-...-fea5f46 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Channel 

type Channel struct {
	IsUsed   bool
	CH       *amqp.Channel
	Identify string
}

Channel Channel

type Connection 

type Connection struct {
	// contains filtered or unexported fields
}

Connection Connection

func (*Connection) CloseChannel 

func (c *Connection) CloseChannel(channel *Channel)

CloseChannel CloseChannel

func (*Connection) Connect 

func (c *Connection) Connect(mqAddress string)

Connect Connect

func (*Connection) GetChannel 

func (c *Connection) GetChannel() (*Channel, error)

GetChannel GetChannel

func (*Connection) GetChannelCount 

func (c *Connection) GetChannelCount() int

GetChannelCount 获取Channel数量

type RabbitMqProxy 

type RabbitMqProxy struct {
	// contains filtered or unexported fields
}

RabbitMqProxy RabbitMqProxy

func (*RabbitMqProxy) Dial 

func (r *RabbitMqProxy) Dial(address string)

address amqp://user:pass@hostName:port/vhost Dial connect rabbitmq

func (*RabbitMqProxy) ReceiveFanoutMessage 

func (r *RabbitMqProxy) ReceiveFanoutMessage(subscribe *Subscribe) error

ReceiveFanoutMessage receive p/s message router

func (*RabbitMqProxy) ReceiveQueryMessage 

func (r *RabbitMqProxy) ReceiveQueryMessage(queueName string, messageReceived func(<-chan amqp.Delivery)) error

ReceiveQueryMessage 获取Query

func (*RabbitMqProxy) ReceiveRouterMessage 

func (r *RabbitMqProxy) ReceiveRouterMessage(exchangeName string, routingKeys ...string) (<-chan amqp.Delivery, error)

ReceiveRouterMessage receive p/s message router

func (*RabbitMqProxy) ReceiveTopicMessage 

func (r *RabbitMqProxy) ReceiveTopicMessage(subscribe *Subscribe) error

ReceiveTopicMessage ReceiveTopicMessage

func (*RabbitMqProxy) SendFanoutMessage 

func (r *RabbitMqProxy) SendFanoutMessage(exchangeName string, datas []byte) error

SendFanoutMessage send p/s message router

func (*RabbitMqProxy) SendQueryMessage 

func (r *RabbitMqProxy) SendQueryMessage(queueName string, datas []byte) error

SendQueryMessage 发送Query

func (*RabbitMqProxy) SendRouterMessage 

func (r *RabbitMqProxy) SendRouterMessage(exchangeName string, routingKey string, datas []byte) error

SendRouterMessage send p/s message router

func (*RabbitMqProxy) SendTopicMessage 

func (r *RabbitMqProxy) SendTopicMessage(exchangeName string, routingKey string, datas []byte) error

SendTopicMessage send p/s message router

type Subscribe 

type Subscribe struct {
	ExchangeName    string
	QueueName       string
	RoutingKey      string
	MessageReceived func([]byte)
}

Subscribe Subscribe

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.