Class: Switchboard::Commands::PubSub::Subscriptions
- Inherits:
-
Switchboard::Command
- Object
- Switchboard::Command
- Switchboard::Commands::PubSub::Subscriptions
- Defined in:
- lib/switchboard/commands/pubsub/subscriptions.rb
Class Method Summary collapse
Methods inherited from Switchboard::Command
description, help, options, to_command, to_command_name
Class Method Details
.run! ⇒ Object
7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 |
# File 'lib/switchboard/commands/pubsub/subscriptions.rb', line 7 def self.run! switchboard = Switchboard::Client.new do # this executes in the main loop, so it doesn't really matter that this runs in a different thread defer :subscriptions_received do subscriptions(settings["pubsub.node"]) end # define here or as hydrant.subscriptions_received def subscriptions_received(subscriptions) if subscriptions && subscriptions.any? puts "Subscriptions:" puts subscriptions.collect { |subscription| [subscription.subid, "#{subscription.jid || settings["jid"]} => #{subscription.node} (#{subscription.state})"].compact * ": " } * "\n" else puts "No subscriptions." end end end if defined?(OAuth) && OPTIONS["oauth"] switchboard.plug!(OAuthPubSubJack) else switchboard.plug!(PubSubJack) end switchboard.run! end |