Contents

module OnsOnRails
  module Publishers
    class Tcp
      def initialize(options)
        @client = Ons::Producer.new(options.fetch(:access_key), options.fetch(:secret_key), options.fetch(:producer_id))
        @client.start
      end

      def publish(topic, tag, body, key)
        @client.send_message(topic, tag, body, key)
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
ons_on_rails-1.0.2	lib/ons_on_rails/publishers/tcp.rb
ons_on_rails-1.0.1	lib/ons_on_rails/publishers/tcp.rb
ons_on_rails-1.0.0	lib/ons_on_rails/publishers/tcp.rb