rabbitmq

package

v0.1.1 Latest Latest Go to latest Published: Jul 22, 2022 License: MIT Imports: 5 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/gole-dev/gole

Links

Open Source Insights

Documentation ¶

Index ¶

func OpenConnection(addr string) (*amqp.Connection, error)
type Channel
- func NewChannel(conn *amqp.Connection) Channel
- func (c Channel) Create() (*amqp.Channel, error)
type Consumer
- func NewConsumer(addr, exchange, queueName string, autoDelete bool, ...) *Consumer
type Producer
- func NewProducer(addr, exchange string) *Producer
type Queue
- func NewQueue(channel *amqp.Channel, name string) Queue
- func (q Queue) Create() (amqp.Queue, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func OpenConnection ¶

func OpenConnection(addr string) (*amqp.Connection, error)

OpenConnection connect to rabbitmq

Types ¶

type Channel ¶

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

Channel data channel

func NewChannel ¶

func NewChannel(conn *amqp.Connection) Channel

NewChannel instance a channel

func (Channel) Create ¶

func (c Channel) Create() (*amqp.Channel, error)

Create create a channel

type Consumer ¶

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

Consumer define consumer for rabbitmq

func NewConsumer ¶

func NewConsumer(addr, exchange, queueName string, autoDelete bool, handler func(body []byte) error) *Consumer

NewConsumer instance a consumer

func (*Consumer) Handle ¶

func (c *Consumer) Handle(delivery <-chan amqp.Delivery)

Handle handle data

func (*Consumer) ReConnect ¶

func (c *Consumer) ReConnect()

ReConnect .

func (*Consumer) Run ¶

func (c *Consumer) Run() error

Run .

func (*Consumer) Start ¶

func (c *Consumer) Start() error

Start start a service

func (*Consumer) Stop ¶

func (c *Consumer) Stop()

Stop a consumer

type Producer ¶

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

Producer define struct for rabbitmq

func NewProducer ¶

func NewProducer(addr, exchange string) *Producer

NewProducer create a producer

func (*Producer) Publish ¶

func (p *Producer) Publish(routingKey, message string) error

Publish push data to queue

func (*Producer) ReConnect ¶

func (p *Producer) ReConnect()

ReConnect .

func (*Producer) Run ¶

func (p *Producer) Run() error

Run .

func (*Producer) Start ¶

func (p *Producer) Start() error

Start start a producer

func (*Producer) Stop ¶

func (p *Producer) Stop()

Stop .

type Queue ¶

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

Queue .

func NewQueue ¶

func NewQueue(channel *amqp.Channel, name string) Queue

NewQueue .

func (Queue) Create ¶

func (q Queue) Create() (amqp.Queue, error)

Create .

Source Files ¶

View all Source files

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