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