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

Inherits:
Data
  • Object
show all
Defined in:
lib/amqp/client/channel.rb

Overview

Response when subscribing (starting a consumer)

Basic collapse

Basic collapse

Instance Attribute Details

#channel_id ⇒ Object (readonly)

Returns the value of attribute channel_id

Returns:

  • (Object) —

    the current value of channel_id



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

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

#consumer_tag ⇒ Object (readonly)

Returns the value of attribute consumer_tag

Returns:

  • (Object) —

    the current value of consumer_tag



324
 
# 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



324
325
326
 
# 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



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

def on_cancel
  @on_cancel
end

#worker_threads ⇒ Object (readonly)

Returns the value of attribute worker_threads

Returns:

  • (Object) —

    the current value of worker_threads



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

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

Instance Method Details

#channel_id=(value) ⇒ Integer (readonly)

Returns The channel ID.

Returns:

  • (Integer) —

    The channel ID



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

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

#consumer_tag=(value) ⇒ String (readonly)

Returns The consumer tag.

Returns:

  • (String) —

    The consumer tag



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

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

#worker_threads=(value) ⇒ Array<Thread> (readonly)

Returns Array of worker threads.

Returns:

  • (Array<Thread>) —

    Array of worker threads



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

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