class Fluffle::Testing::Loopback::Channel

Public Class Methods

new(server) click to toggle source
# File lib/fluffle/testing.rb, line 114
def initialize(server)
  @server = server

  @confirm_select      = nil
  @next_publish_seq_no = 0
end

Public Instance Methods

ack(delivery_tag, multiple = false) click to toggle source
# File lib/fluffle/testing.rb, line 155
def ack(delivery_tag, multiple = false)
  true
end
close() click to toggle source
# File lib/fluffle/testing.rb, line 159
def close
end
confirm_select(block = nil) click to toggle source
# File lib/fluffle/testing.rb, line 125
def confirm_select(block = nil)
  @confirm_select      = block
  @next_publish_seq_no = 1
end
default_exchange() click to toggle source
# File lib/fluffle/testing.rb, line 121
def default_exchange
  @default_exchange ||= Exchange.new(@server, self)
end
next_publish_seq_no() click to toggle source
# File lib/fluffle/testing.rb, line 130
def next_publish_seq_no
  @next_publish_seq_no
end
prefetch(number, global = false) click to toggle source
# File lib/fluffle/testing.rb, line 134
def prefetch(number, global = false)
end
publish(payload, opts) click to toggle source
# File lib/fluffle/testing.rb, line 143
def publish(payload, opts)
  if @confirm_select
    multiple = false
    nack = false
    @confirm_select.call @next_publish_seq_no, multiple, nack
  end

  @server.publish payload, opts

  @next_publish_seq_no += 1 if @next_publish_seq_no > 0
end
queue(name, **opts) click to toggle source
# File lib/fluffle/testing.rb, line 137
def queue(name, **opts)
  opts = opts.merge server: @server

  Queue.new name, opts
end