class AwsIotDevice::MqttAdapter::PahoMqttAdapter
Public Class Methods
new(*args)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 7 def initialize(*args) @client = PahoMqtt::Client.new(*args) end
Public Instance Methods
add_callback_filter_topic(topic, callback=nil, &block)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 110 def add_callback_filter_topic(topic, callback=nil, &block) @client.add_topic_callback(topic, callback, &block) end
client_id()
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 11 def client_id @client.client_id end
connect(*args) { |self| ... }
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 15 def connect(*args, &block) if args.last.is_a?(Hash) attr = args.last attr.each_pair do |k, v| if [:host, :port, :keep_alive, :persistent].include?(k) @client.send("#{k}=", v) else raise ArgumentError, "Parameter error, invalid paramater \"#{k}\" for connect with paho-mqtt" end end end @client.connect if block_given? begin yield(self) ensure @mqtt_client.disconnect end end end
connected?()
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 86 def connected? @client.connected? end
disconnect(send_msg)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 82 def disconnect(send_msg) @client.disconnect(send_msg) end
generate_client_id()
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 78 def generate_client_id @client.generate_client_id end
get(topic=nil, &block)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 70 def get(topic=nil, &block) @client.loop_read(1) end
get_packet(topic=nil, &block)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 74 def get_packet(topic=nil, &block) @client.loop_read(1) end
host()
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 182 def host @client.host end
host=(host)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 186 def host=(host) @client.host = host end
loop_forever()
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 48 def loop_forever loop do @client.mqtt_loop end end
loop_misc()
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 66 def loop_misc @client.loop_misc end
loop_read()
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 58 def loop_read @client.loop_read end
loop_start()
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 40 def loop_start Thread.new { loop_forever } end
loop_stop(thread)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 44 def loop_stop(thread) thread.join end
loop_write()
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 62 def loop_write @client.loop_write end
mqtt_loop()
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 54 def mqtt_loop @client.mqtt_loop end
on_connack(&block)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 150 def on_connack(&block) @client.on_connack(&block) end
on_connack=(callback)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 118 def on_connack=(callback) @client.on_connack = callback end
on_message(&block)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 178 def on_message(&block) @client.on_message(&block) end
on_message=(callback)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 146 def on_message=(callback) @client.on_message = callback end
on_puback(&block)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 162 def on_puback(&block) @client.on_puback(&block) end
on_puback=(callback)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 130 def on_puback=(callback) @client.on_puback = callback end
on_pubcomp(&block)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 174 def on_pubcomp(&block) @client.on_pubcomp(&block) end
on_pubcomp=(callback)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 142 def on_pubcomp=(callback) @client.on_pubcomp = callback end
on_pubrec(&block)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 166 def on_pubrec(&block) @client.on_pubrec(&block) end
on_pubrec=(callback)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 134 def on_pubrec=(callback) @client.on_pubrec = callback end
on_pubrel(&block)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 170 def on_pubrel(&block) @client.on_pubrel(&block) end
on_pubrel=(callback)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 138 def on_pubrel=(callback) @client.on_pubrel = callback end
on_suback(&block)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 154 def on_suback(&block) @client.on_suback(&block) end
on_suback=(callback)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 122 def on_suback=(callback) @client.on_suback = callback end
on_unsuback(&block)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 158 def on_unsuback(&block) @client.on_unsuback(&block) end
on_unsuback=(callback)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 126 def on_unsuback=(callback) @client.on_unsuback = callback end
port()
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 190 def port @client.port end
port=(port)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 194 def port=(port) @client.port = port end
publish(topic, payload="", retain=false, qos=0)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 36 def publish(topic, payload="", retain=false, qos=0) @client.publish(topic, payload, retain, qos) end
remove_callback_filter_topic(topic)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 114 def remove_callback_filter_topic(topic) @client.remove_topic_callback(topic) end
set_tls_ssl_context(ca_cert=nil, cert=nil, key=nil)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 106 def set_tls_ssl_context(ca_cert=nil, cert=nil, key=nil) @client.config_ssl_context(cert, key, ca_cert) end
ssl()
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 198 def ssl @client.ssl end
ssl=(ssl)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 202 def ssl=(ssl) @client.ssl = ssl end
subscribe(topic, qos)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 90 def subscribe(topic, qos) @client.subscribe([topic, qos]) end
subscribe_bunch(topics)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 94 def subscribe_bunch(topics) @client.subscribe(topics) end
unsubscribe(topic)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 98 def unsubscribe(topic) @client.unsubscribe(topic) end
unsubscribe_bunch(topics)
click to toggle source
# File lib/aws_iot_device/mqtt_adapter/paho_mqtt_adapter.rb, line 102 def unsubscribe_bunch(topics) @client.unsubscribe(topics) end