Contents

#!/usr/bin/env ruby
# frozen_string_literal: true

require "bundler/setup"
require "boom_nats"

class MyTopic < BoomNats::Topic
  def consume
    {
      hello: params["name"]
    }
  rescue StandardError => e
    puts e.message
  end
end

BoomNats.setup do
  servers "nats://0.0.0.0:4222"

  draw_routes do
    in_queue "test" do
      topic "hello", MyTopic
    end
  end
end

BoomNats.application.start

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
boom_nats-0.1.5	bin/example
boom_nats-0.1.4	bin/example
boom_nats-0.1.3	bin/example
boom_nats-0.1.2	bin/example
boom_nats-0.1.1	bin/example
boom_nats-0.1.0	bin/example