Documentation ¶
Index ¶
- type ClientRabbitMQ
- func (r *ClientRabbitMQ) BindQueue(queue, exchange string, keys []string, nowait bool) (err error)
- func (r *ClientRabbitMQ) Close() (err error)
- func (r *ClientRabbitMQ) Connect() (err error)
- func (r *ClientRabbitMQ) ConsumeQueue(queue string, message chan []byte) (err error)
- func (r *ClientRabbitMQ) DeclareExchange(name, typ string, durable, autoDelete, nowait bool) (err error)
- func (r *ClientRabbitMQ) DeclareQueue(name string, durable, autoDelete, exclusive, nowait bool) (err error)
- func (r *ClientRabbitMQ) DeleteExchange(name string) (err error)
- func (r *ClientRabbitMQ) DeleteQueue(name string) (err error)
- func (r *ClientRabbitMQ) Publish(exchange, key string, deliveryMode, priority uint8, body string) (err error)
- func (r *ClientRabbitMQ) UnBindQueue(queue, exchange string, keys []string) (err error)
- type ExchangeEntity
- type MessageEntity
- type QueueBindEntity
- type QueueEntity
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientRabbitMQ ¶
type ClientRabbitMQ struct {
// contains filtered or unexported fields
}
ClientRabbitMQ Operate Wrapper
func (*ClientRabbitMQ) BindQueue ¶
func (r *ClientRabbitMQ) BindQueue(queue, exchange string, keys []string, nowait bool) (err error)
func (*ClientRabbitMQ) Close ¶
func (r *ClientRabbitMQ) Close() (err error)
func (*ClientRabbitMQ) Connect ¶
func (r *ClientRabbitMQ) Connect() (err error)
func (*ClientRabbitMQ) ConsumeQueue ¶
func (r *ClientRabbitMQ) ConsumeQueue(queue string, message chan []byte) (err error)
func (*ClientRabbitMQ) DeclareExchange ¶
func (r *ClientRabbitMQ) DeclareExchange(name, typ string, durable, autoDelete, nowait bool) (err error)
func (*ClientRabbitMQ) DeclareQueue ¶
func (r *ClientRabbitMQ) DeclareQueue(name string, durable, autoDelete, exclusive, nowait bool) (err error)
func (*ClientRabbitMQ) DeleteExchange ¶
func (r *ClientRabbitMQ) DeleteExchange(name string) (err error)
func (*ClientRabbitMQ) DeleteQueue ¶
func (r *ClientRabbitMQ) DeleteQueue(name string) (err error)
func (*ClientRabbitMQ) Publish ¶
func (r *ClientRabbitMQ) Publish(exchange, key string, deliveryMode, priority uint8, body string) (err error)
func (*ClientRabbitMQ) UnBindQueue ¶
func (r *ClientRabbitMQ) UnBindQueue(queue, exchange string, keys []string) (err error)
type ExchangeEntity ¶
type MessageEntity ¶
type MessageEntity struct { Exchange string `json:"exchange"` Key string `json:"key"` DeliveryMode uint8 `json:"deliveryMode"` Priority uint8 `json:"priority"` Body string `json:"body"` }
Entity for HTTP Request Body: Message/Exchange/Queue/QueueBind JSON Input
type QueueBindEntity ¶
Click to show internal directories.
Click to hide internal directories.