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

Version Path
boom_nats-0.1.5 lib/boom_nats/router.rb
boom_nats-0.1.4 lib/boom_nats/router.rb
boom_nats-0.1.3 lib/boom_nats/router.rb
boom_nats-0.1.2 lib/boom_nats/router.rb
boom_nats-0.1.1 lib/boom_nats/router.rb
boom_nats-0.1.0 lib/boom_nats/router.rb