Class: AMQP::Client::Connection::Channel::ConsumeOk

Inherits:

Data

• Object
• Data
• AMQP::Client::Connection::Channel::ConsumeOk

Defined in:

lib/amqp/client/channel.rb

Overview

Response when subscribing (starting a consumer)

Basic

• #channel_id ⇒ Integer

  The channel ID.

• #consumer_tag ⇒ String

  The consumer tag.

• #msg_q ⇒ Object readonly

  Returns the value of attribute msg_q.

• #on_cancel ⇒ Object readonly

  Returns the value of attribute on_cancel.

• #worker_threads ⇒ Array<Thread>

  Array of worker threads.

Instance Attribute Details

#channel_id ⇒ Integer

Returns The channel ID.

Returns:

• (Integer) —

  The channel ID

# File 'lib/amqp/client/channel.rb', line 324

ConsumeOk = Data.define(:channel_id, :consumer_tag, :worker_threads, :msg_q, :on_cancel)

#consumer_tag ⇒ String

Returns The consumer tag.

Returns:

• (String) —

  The consumer tag

# File 'lib/amqp/client/channel.rb', line 324

ConsumeOk = Data.define(:channel_id, :consumer_tag, :worker_threads, :msg_q, :on_cancel)

#msg_q ⇒ Object (readonly)

Returns the value of attribute msg_q

Returns:

• (Object) —

  the current value of msg_q

# File 'lib/amqp/client/channel.rb', line 324

def msg_q
  @msg_q
end

#on_cancel ⇒ Object (readonly)

Returns the value of attribute on_cancel

Returns:

• (Object) —

  the current value of on_cancel

# File 'lib/amqp/client/channel.rb', line 324

def on_cancel
  @on_cancel
end

#worker_threads ⇒ Array<Thread>

Returns Array of worker threads.

Returns:

• (Array<Thread>) —

  Array of worker threads

# File 'lib/amqp/client/channel.rb', line 324

ConsumeOk = Data.define(:channel_id, :consumer_tag, :worker_threads, :msg_q, :on_cancel)