Contents

require "magellan/cli/messaging"

module Magellan
  module Cli
    module Messaging
      class Mqtt < Magellan::Cli::Messaging::Base

        desc "pub TOPIC PAYLOAD", I18n.t(:pub, scope: [:messaging, :mqtt])
        def pub(topic, payload)
          core.publish(topic, try_reading_file(payload).dup)
          log_success "\e[32mOK\e[0m"
        rescue => e
          show_error_and_exit1(e)
        end

        desc "get [TOPIC]", I18n.t(:get, scope: [:messaging, :mqtt])
        def get(topic = nil)
          topic, payload = *core.get_message(topic)
          $stderr.puts topic
          $stdout.puts payload.ascii_only? ? payload : payload.inspect
        rescue => e
          show_error_and_exit1(e)
        end

      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
magellan-cli-0.5.7	lib/magellan/cli/messaging/mqtt.rb
magellan-cli-0.5.6	lib/magellan/cli/messaging/mqtt.rb
magellan-cli-0.5.5	lib/magellan/cli/messaging/mqtt.rb