class Fluffle::Testing::Loopback::Queue

Attributes

name[R]

Public Class Methods

new(name, server:, **opts) click to toggle source
# File lib/fluffle/testing.rb, line 180
def initialize(name, server:, **opts)
  @name   = name
  @server = server
end

Public Instance Methods

subscribe(opts = {}, &block) click to toggle source
# File lib/fluffle/testing.rb, line 185
def subscribe(opts = {}, &block)
  @server.add_queue_subscriber @name, block
end