module RailwayIpc::RPC::MessageObservationConfigurable
Public Instance Methods
exchange_name()
click to toggle source
# File lib/railway_ipc/rpc/concerns/message_observation_configurable.rb, line 15 def exchange_name @exchange_name end
listen_to(queue:, exchange:)
click to toggle source
# File lib/railway_ipc/rpc/concerns/message_observation_configurable.rb, line 6 def listen_to(queue:, exchange:) @exchange_name = exchange @queue_name = queue end
queue_name()
click to toggle source
# File lib/railway_ipc/rpc/concerns/message_observation_configurable.rb, line 11 def queue_name @queue_name end