rabbitmq

package

v0.0.0-...-0871eb3 Latest Latest Go to latest Published: Feb 4, 2021 License: MIT Imports: 4 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

This section is empty.

View Source

var ContentTypes = []string{
	"text/plain",
	"application/json",
	"text/html",
	"text/xml",
}

ContentTypes is content type of messages

func SetContentType(val uint8)

SetContentType is to set default ContentType

type RM struct {
	DB *amqp.Connection
	Ch *amqp.Channel
}

RM is struct of RabitMQ object

func New(host, user, pass string, port int) *RM

New is to connect to RabbitMQ server

func (r *RM) Close()

Close is to close connection

func (r *RM) CloseChannel()

CloseChannel is to close connection to channel

func (r *RM) CreateChannel()

CreateChannel is to create channel

func (r *RM) CreateConsume(name string, chBody chan []byte) (<-chan amqp.Delivery, error)

CreateConsume is to create Consume

func (r *RM) CreateReceiver(name string, chBody chan []byte)

CreateReceiver is for consumer

func (r *RM) Declare(name string) *amqp.Queue

Declare is to declare of queue name

func (r *RM) Send(body []byte, q *amqp.Queue)

Send is for producer