Class: Magellan::Cli::Messaging::Mqtt

Inherits:
Base show all
Defined in:
lib/magellan/cli/messaging/mqtt.rb

Constant Summary

Constants included from FileAccess

FileAccess::DEFAULT_SELECTION_FILENAME

Instance Method Summary collapse

Methods included from FileAccess

ensure_config_dir, load_selection, load_selections, remove_selection_file, selection_filename, update_selections

Methods inherited from Base

command_help, help, log_error, log_info, log_success, log_verbose, puts_with_color, sorted_commands, sorted_printable_commands, update_common_help_message

Instance Method Details

#get(topic = nil) ⇒ Object 



17
18
19
20
21
22
23
 
# File 'lib/magellan/cli/messaging/mqtt.rb', line 17

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

#pub(topic, payload) ⇒ Object 



9
10
11
12
13
14
 
# File 'lib/magellan/cli/messaging/mqtt.rb', line 9

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