Method: Krakow::Distribution#remove_connection

Defined in:
lib/krakow/distribution.rb

#remove_connection(connection_identifier, *args) ⇒ TrueClass

Remove connection from RDY distribution

Parameters:

  • connection_identifier (String)

Returns:

  • (TrueClass) 


139
140
141
142
143
144
145
146
147
148
149
150
 
# File 'lib/krakow/distribution.rb', line 139

def remove_connection(connection_identifier, *args)
  # remove connection from registry
  registry.delete(connection_identifier)
  # remove any in flight messages
  flight_record.delete_if do |k,v|
    if(v == connection_identifier)
      warn "Removing in flight reference due to failed connection: #{v}"
      true
    end
  end
  true
end