Class: RubyRabbitmqJanus::Rabbit::Publisher::Keepalive
- Defined in:
- lib/rrj/rabbit/publisher/keepalive.rb
Overview
# Publish message for keepalive thread
The name to queue it’s created automatically by Bunny GEM
Instance Attribute Summary
Attributes inherited from BaseEvent
Instance Method Summary collapse
-
#initialize(exchange) ⇒ Keepalive
constructor
A new instance of Keepalive.
- #publish(request) ⇒ Object
Constructor Details
#initialize(exchange) ⇒ Keepalive
Returns a new instance of Keepalive.
14 15 16 17 18 |
# File 'lib/rrj/rabbit/publisher/keepalive.rb', line 14 def initialize(exchange) @reply = exchange.queue('', exclusive: true) super(exchange) subscribe_to_queue end |
Instance Method Details
#publish(request) ⇒ Object
20 21 22 23 |
# File 'lib/rrj/rabbit/publisher/keepalive.rb', line 20 def publish(request) super(request) return_response end |