Module: RailwayIpc::RPC::MessageObservationConfigurable

Included in:
Server
Defined in:
lib/railway_ipc/rpc/concerns/message_observation_configurable.rb

Instance Method Summary collapse

Instance Method Details

#exchange_name ⇒ Object 



15
16
17
 
# File 'lib/railway_ipc/rpc/concerns/message_observation_configurable.rb', line 15

def exchange_name
  @exchange_name
end

#listen_to(exchange:, queue:) ⇒ Object 



6
7
8
9
 
# File 'lib/railway_ipc/rpc/concerns/message_observation_configurable.rb', line 6

def listen_to(exchange:, queue:)
  @exchange_name = exchange
  @queue_name = queue
end

#queue_name ⇒ Object 



11
12
13
 
# File 'lib/railway_ipc/rpc/concerns/message_observation_configurable.rb', line 11

def queue_name
  @queue_name
end