class

Amqp::Subscription

Inherits Reference < Object

A live consumer registration. Iterate over receive to consume. When the broker cancels the consumer (e.g., queue deleted) or the channel closes, receive raises SubscriptionClosed.

Instance methods

channel
Source
close
Source
closed?
Source
consumer_tag
Source
each
Source
queue
Source
receive
Source
receive?
Source
receive_select_action

Select support for select; when msg = sub.receive; ...; end.

Source
receive_select_action?
Source
spawn_loop
Source

Nested types