Class: RubyRabbitmqJanus::Rabbit::Publisher::Admin
- Defined in:
- lib/rrj/rabbit/publisher/admin.rb
Overview
This publisher send and read an message in admin queues
Instance Attribute Summary
Attributes inherited from BaseEvent
Instance Method Summary collapse
-
#initialize(exchange) ⇒ Admin
constructor
Initialize an queue non eclusive for admin/monitor API with Janus.
-
#publish(request) ⇒ Janus::Response::Admin
Send an message to queue and waiting a response.
Constructor Details
Instance Method Details
#publish(request) ⇒ Janus::Response::Admin
Send an message to queue and waiting a response
27 28 29 30 31 32 |
# File 'lib/rrj/rabbit/publisher/admin.rb', line 27 def publish(request) @message = request @exchange.publish(@message.to_json, request..merge!(reply_to: reply.name)) return_response end |