MCPcopy
hub / github.com/nats-io/nats.go / QueuedMsgs

Method QueuedMsgs

nats.go:5583–5586  ·  view source on GitHub ↗

Queued returns the number of queued messages in the client for this subscription. Deprecated: Use Pending()

()

Source from the content-addressed store, hash-verified

5581//
5582// Deprecated: Use Pending()
5583func (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.
5589func (s *Subscription) Pending() (int, int, error) {

Callers

nothing calls this directly

Calls 1

PendingMethod · 0.95

Tested by

no test coverage detected