Sha256: 3049fcaaa9f5ae32846c06797cc91da41ddcedcc0ef56c348b4e523ca497c068
Contents?: true
Size: 486 Bytes
Versions: 6
Compression:
Stored size: 486 Bytes
Contents
module BoomNats class Router def initialize(application) @application = application end def setup(&block) instance_eval(&block) end def in_queue(name, &block) @current_group = name instance_eval(&block) @current_group = nil end def topic(name, klass, options = {}) options = { queue: @current_group, **options } RouteTopic.new(@application).setup(name, klass, **options) end end end
Version data entries
6 entries across 6 versions & 1 rubygems