Documentation ¶
Index ¶
- type AmqpConfig
- type Client
- func (client *Client) CloseConsume(consume *Consume) error
- func (client *Client) Consume(queueName string, isReplyBy bool, isQuorum bool) (*Consume, error)
- func (client *Client) Init(config AmqpConfig, prefetchCount int, wg *sync.WaitGroup)
- func (client *Client) IsReady() bool
- func (client *Client) Publish(channel *amqp.Channel, route string, body []byte, replyTo *string) error
- func (client *Client) Run(ctx context.Context) error
- func (client *Client) Shutdown(ctx context.Context)
- type Consume
- type Consumer
- type Consuming
- type Request
- type Response
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AmqpConfig ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) CloseConsume ¶
func (*Client) Init ¶
func (client *Client) Init(config AmqpConfig, prefetchCount int, wg *sync.WaitGroup)
type Consuming ¶
type Consuming struct {
// contains filtered or unexported fields
}
func NewConsuming ¶
func (*Consuming) AddConsumer ¶
Click to show internal directories.
Click to hide internal directories.