Contents

require 'huginn/internal/message'

module Huginn
  class Client
    include Celluloid

    DEFAULT_HOST = 'tcp://localhost:1883'

    def initialize(opts = {})
      @server_uri = opts.fetch(:server_uri) { DEFAULT_HOST }
    end

    def send_message(topic, payload)
      Internal::Message.new_link(topic, payload).deliver
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
huginn-0.0.1.alpha	lib/huginn/client.rb