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