Queued returns the number of queued messages in the client for this subscription. Deprecated: Use Pending()
()
| 5581 | // |
| 5582 | // Deprecated: Use Pending() |
| 5583 | func (s *Subscription) QueuedMsgs() (int, error) { |
| 5584 | m, _, err := s.Pending() |
| 5585 | return int(m), err |
| 5586 | } |
| 5587 | |
| 5588 | // Pending returns the number of queued messages and queued bytes in the client for this subscription. |
| 5589 | func (s *Subscription) Pending() (int, int, error) { |