Class: ForeignOffice::Busses::PubnubBus
- Inherits:
-
GenericBus
- Object
- GenericBus
- ForeignOffice::Busses::PubnubBus
- Defined in:
- lib/foreign_office/busses/pubnub_bus.rb
Class Method Summary collapse
- .config(config) ⇒ Object
- .connection ⇒ Object
- .publish(message) ⇒ Object
- .publish_key ⇒ Object
- .publish_key=(publish_key) ⇒ Object
- .secret_key ⇒ Object
- .secret_key=(secret_key) ⇒ Object
- .subscribe_key ⇒ Object
- .subscribe_key=(subscribe_key) ⇒ Object
Methods inherited from GenericBus
Class Method Details
.config(config) ⇒ Object
3 4 5 6 7 |
# File 'lib/foreign_office/busses/pubnub_bus.rb', line 3 def self.config(config) self.publish_key = config[:publish_key] self.subscribe_key = config[:subscribe_key] self.secret_key = config[:secret_key] end |
.connection ⇒ Object
33 34 35 36 37 38 39 40 |
# File 'lib/foreign_office/busses/pubnub_bus.rb', line 33 def self.connection @pubnub ||= ::Pubnub.new( publish_key: self.publish_key, # publish_key only required if publishing. subscribe_key: self.subscribe_key, # required secret_key: self.secret_key, ssl: true ) end |
.publish(message) ⇒ Object
42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 |
# File 'lib/foreign_office/busses/pubnub_bus.rb', line 42 def self.publish() .symbolize_keys! self.connection.publish( channel: [:channel], message: , http_sync: true ) do |envelope| if '200' != envelope.status_code.to_s Rails.logger.error "ForeignOffice error esponse:" Rails.logger.error envelope. Rails.logger.error envelope.channel Rails.logger.error envelope.status_code Rails.logger.error envelope.timetoken end end end |
.publish_key ⇒ Object
13 14 15 |
# File 'lib/foreign_office/busses/pubnub_bus.rb', line 13 def self.publish_key @publish_key end |
.publish_key=(publish_key) ⇒ Object
9 10 11 |
# File 'lib/foreign_office/busses/pubnub_bus.rb', line 9 def self.publish_key=(publish_key) @publish_key = publish_key end |
.secret_key ⇒ Object
29 30 31 |
# File 'lib/foreign_office/busses/pubnub_bus.rb', line 29 def self.secret_key @secret_key end |
.secret_key=(secret_key) ⇒ Object
25 26 27 |
# File 'lib/foreign_office/busses/pubnub_bus.rb', line 25 def self.secret_key=(secret_key) @secret_key = secret_key end |
.subscribe_key ⇒ Object
21 22 23 |
# File 'lib/foreign_office/busses/pubnub_bus.rb', line 21 def self.subscribe_key @subscribe_key end |
.subscribe_key=(subscribe_key) ⇒ Object
17 18 19 |
# File 'lib/foreign_office/busses/pubnub_bus.rb', line 17 def self.subscribe_key=(subscribe_key) @subscribe_key = subscribe_key end |