ruby-mqtt

ruby-mqtt copied to clipboard

Hey folks, I'm trying to establish a non clean session on my "subscriber", but it doesn't seem to work. I've verified that QoS1 is on the publisher by using `mosquito_sub`...

dmitrym0

andreimerlescu

njh

Avoid to close @socket of MQTT::Client unexpectedly

2

Since it is locked only when writing, it may be closed by anothre thread while reading or writing. In actual we often get the following error when we are processing...

ashie

Assume publish response as ping response

1

Fixes #127 This option should be needed due to high frequently traffic environment. When flood of messages are reached in this client, keep_alive! response may not reached until response timeout...

cosmo0920

Derive Exceptions from StandardError

5

Thanks for the nice library. I think that exceptions should be derived from the ruby `StandardError`. This makes it possible to rescue them in a general rescue block. It will...

ahanak

fix: reset ping timers on connect

1

#107

crawler

Do nonblocking socket read before select for packet receive

1

I've periodically run into some cases where the `receive_packet` method hangs indefinitely on an `IO.select` even though the underlying network socket has actually received some bytes from the network for...

camlow325

Add support for external event driven API

11

- http://ruby-doc.org/stdlib-2.3.1/libdoc/observer/rdoc/Observable.html - https://github.com/briandamaged/unobservable - https://github.com/mikbe/eventable - https://github.com/celluloid/celluloid - https://github.com/shokai/event_emitter - https://briandamaged.org/blog/ruby-event-handlers/

njh

When flood of messages are reached in this client on weak CPU environment, keep_alive! response may not reached until response timeout and causes MQTT::ProtocolException with "No Ping Response received for...

cosmo0920