Module: ZZQ

Defined in:: lib/zzq.rb,
lib/zzq/error.rb,
lib/zzq/broker.rb,
lib/zzq/client.rb,
lib/zzq/engine.rb,
lib/zzq/socket.rb,
lib/zzq/message.rb,
lib/zzq/options.rb,
lib/zzq/version.rb,
lib/zzq/subscription.rb,
lib/zzq/monitor_event.rb,
lib/zzq/transport/ipc.rb,
lib/zzq/routing/broker.rb,
lib/zzq/routing/client.rb,
lib/zzq/transport/mqtt.rb,
lib/zzq/transport/mqtts.rb,
lib/zzq/engine/keepalive.rb,
lib/zzq/persistence/memory.rb,
lib/zzq/persistence/pstore.rb,
lib/zzq/routing/topic_trie.rb,
lib/zzq/routing/qos_tracker.rb,
lib/zzq/routing/topic_match.rb,
lib/zzq/persistence/interface.rb,
lib/zzq/routing/retained_store.rb,
lib/zzq/engine/socket_lifecycle.rb,
lib/zzq/engine/connection_lifecycle.rb,
lib/zzq/routing/packet_id_allocator.rb

Overview

ZZQ — async-native MQTT client and broker for Ruby.

Built on ‘async`, `io-stream`, and `protocol-mqtt`. Applies the omq/nnq architecture (Socket base, Engine, pluggable transports, barrier-scoped lifecycle) to MQTT 3.1.1 and 5.0.

Defined Under Namespace

Modules: Persistence, Routing, Transport Classes: AuthFailed, Broker, Client, ClosedError, ConnectionRefused, ConnectionRejected, Engine, Error, Message, MonitorEvent, NotInAsyncContext, Options, Socket, Subscription

Constant Summary collapse

CONNECTION_LOST = Network errors that indicate the connection is gone.

[
  Errno::ECONNRESET, Errno::EPIPE, Errno::ENOTCONN, Errno::ECONNABORTED,
  Errno::EBADF, EOFError, IOError
].freeze

VERSION =

"0.1.0"