Documentation ¶
Index ¶
- Variables
- func SetContentType(val uint8)
- type RM
- func (r *RM) Close()
- func (r *RM) CloseChannel()
- func (r *RM) CreateChannel()
- func (r *RM) CreateConsume(name string, chBody chan []byte) (<-chan amqp.Delivery, error)
- func (r *RM) CreateReceiver(name string, chBody chan []byte)
- func (r *RM) Declare(name string) *amqp.Queue
- func (r *RM) Send(body []byte, q *amqp.Queue)
Constants ¶
This section is empty.
Variables ¶
View Source
var ContentTypes = []string{
"text/plain",
"application/json",
"text/html",
"text/xml",
}
ContentTypes is content type of messages
Functions ¶
Types ¶
type RM ¶
type RM struct { DB *amqp.Connection Ch *amqp.Channel }
RM is struct of RabitMQ object
func (*RM) CloseChannel ¶
func (r *RM) CloseChannel()
CloseChannel is to close connection to channel
func (*RM) CreateConsume ¶
CreateConsume is to create Consume
func (*RM) CreateReceiver ¶
CreateReceiver is for consumer
Click to show internal directories.
Click to hide internal directories.