Class: Legion::Transport::InProcess::Channel

Inherits:

Object

• Object
• Legion::Transport::InProcess::Channel

Defined in:

lib/legion/transport/in_process.rb

Instance Method Summary

• #acknowledge ⇒ Object
• #basic_qos(count, _global: false) ⇒ Object
• #close ⇒ Object
• #exchange_declare ⇒ Object
• #exchange_delete ⇒ Object
• #initialize ⇒ Channel constructor

  A new instance of Channel.

• #open? ⇒ Boolean
• #prefetch(count, _global: false) ⇒ Object
• #reject ⇒ Object

Constructor Details

#initialize ⇒ Channel

Returns a new instance of Channel.

# File 'lib/legion/transport/in_process.rb', line 54

def initialize
  @open = true
end

Instance Method Details

#acknowledge ⇒ Object

# File 'lib/legion/transport/in_process.rb', line 76

def acknowledge(*); end

#basic_qos(count, _global: false) ⇒ Object

# File 'lib/legion/transport/in_process.rb', line 70

def basic_qos(count, _global: false)
  prefetch(count)
end

#close ⇒ Object

# File 'lib/legion/transport/in_process.rb', line 62

def close
  @open = false
end

#exchange_declare ⇒ Object

# File 'lib/legion/transport/in_process.rb', line 74

def exchange_declare(*); end

#exchange_delete ⇒ Object

# File 'lib/legion/transport/in_process.rb', line 80

def exchange_delete(*); end

#open? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/legion/transport/in_process.rb', line 58

def open?
  @open
end

#prefetch(count, _global: false) ⇒ Object

# File 'lib/legion/transport/in_process.rb', line 66

def prefetch(count, _global: false)
  count
end

#reject ⇒ Object

# File 'lib/legion/transport/in_process.rb', line 78

def reject(*); end