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