Documentation ¶
Index ¶
- type RabbitMQClient
- func (cli *RabbitMQClient) Close() error
- func (cli *RabbitMQClient) Connect(mqurl string) error
- func (cli *RabbitMQClient) GetQueueLength(queueName string) (int, error)
- func (cli *RabbitMQClient) Pop(queueName string, workQueue bool) (string, error)
- func (cli *RabbitMQClient) PopAll(queueName string) (string, error)
- func (cli *RabbitMQClient) Push(queueName, msgContent string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitMQClient ¶
type RabbitMQClient struct {
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(rabbitMQServerIP, rabbitMQServerPort, rabbitMQServerUsr, rabbitMQServerPass, rabbitMQVhost string) (*RabbitMQClient, error)
func (*RabbitMQClient) Close ¶
func (cli *RabbitMQClient) Close() error
func (*RabbitMQClient) Connect ¶
func (cli *RabbitMQClient) Connect(mqurl string) error
func (*RabbitMQClient) GetQueueLength ¶
func (cli *RabbitMQClient) GetQueueLength(queueName string) (int, error)
func (*RabbitMQClient) Pop ¶
func (cli *RabbitMQClient) Pop(queueName string, workQueue bool) (string, error)
func (*RabbitMQClient) Push ¶
func (cli *RabbitMQClient) Push(queueName, msgContent string) error
Click to show internal directories.
Click to hide internal directories.